Golang: Czy mogę rzucić do interfejsu chan {}

Question

Próbuję napisać otoki ogólnego przeznaczenia do subskrypcji, coś jak:

type Subscriber interface{ 
    Subscribe(addr string) chan interface{} 
} 

Załóżmy, że istnieje biblioteka chcę użyć która ma subskrybować metody w to, ale który używa chan library.Object. Chciałbym móc zrobić coś takiego:

func (s *mySubscriber) Subscribe(addr string) chan interface{}{ 
    ch := make(chan library.Object) 
    library.Subscribe(addr, ch) 
    return chan interface{}(ch) 
} 

Obecnie nie wierzę, że taka obsada jest możliwa. I nie chcę modyfikować podstawowej biblioteki, ponieważ opakowanie powinno być agnostyczne dla implementacji biblioteki.

Widziałem już Is there a way to cast Structs for sending over a channel, ale w takim przypadku można zmodyfikować aplikację w zależności od potrzeb. Tutaj nie może. czy to możliwe? Czy istnieje lepszy sposób?

Jednym z rozwiązań jest przejście do kanału Subskrybuj w kanale ogólnego przeznaczenia i czekanie w nieokreślony sposób na chan library.Object i wywoływanie wszystkiego, co pojawia się na moim ogólnym kanale, ale nie bardzo chciałem, aby wprowadzić inny kanał tylko po to, aby obejść typ rzucony.

Answer 1

Nie, nie można tego zrobić za pomocą tylko rzutowania. Musisz użyć dodatkowego kanału, o czym już wcześniej pomyślałeś. Na szczęście istnieje już biblioteka pomocników (disclaimer: napisałem to). Chcesz funkcję Wrap.

• Dokumentacja: https://godoc.org/github.com/eapache/channels#Wrap
• Kod: https://github.com/eapache/channels/

Answer 2

Dla każdego innego, natyka się na ten temat i chce trochę kodu inline:

// wrap a timeout channel in a generic interface channel 
func makeDefaultTimeoutChan() <-chan interface{} { 
    channel := make(chan interface{}) 
    go func() { 
    <-time.After(30 * time.Second) 
    channel <- struct{}{} 
    }() 
    return channel 
} 

// usage 
func main() { 
    resultChannel := doOtherThingReturningAsync() 
    cancel := makeDefaultTimeoutChan() 
    select { 
    case <-cancel: 
     fmt.Println("cancelled!") 
    case results := <-resultChannel: 
     fmt.Printf("got result: %#v\n", results) 
    } 
}