Golang: Kann ich zu gieße chan Schnittstelle {}

Question

Ich versuche, eine Allzweck-Wrapper für Abonnements zu schreiben, so etwas wie:

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

Angenommen, es gibt eine Bibliothek, die ich verwenden möchte, die eine Methode subscribe hat in es, aber die eine chan library.Object verwendet. Ich möchte in der Lage sein, etwas zu tun wie:

Derzeit glaube ich nicht, dass eine solche Besetzung möglich ist. Und ich möchte die zugrunde liegende Bibliothek nicht ändern, da der Wrapper von Bibliotheksimplementierungen unabhängig sein sollte.

Ich habe Is there a way to cast Structs for sending over a channel gesehen, aber in diesem Fall kann die Anwendung geändert werden, um den Bedarf zu erfüllen. Hier kann es nicht. Ist das möglich? Gibt es einen besseren Weg? Eine Lösung besteht darin, in einem Allzweckkanal in Subscribe zu gehen und unablässig auf chan library.Object zu warten und alles abzufeuern, das auf meinem allgemeinen Kanal ankommt, aber ich habe nicht besonders gerne einen anderen Kanal einführen müssen, nur um herumzukommen der Typ gegossen.

Answer 1

Nein, Sie können dies nicht mit nur einer Besetzung tun. Sie müssen einen zusätzlichen Kanal verwenden, wie Sie bereits in Erwägung gezogen haben. Zum Glück gibt es dafür bereits eine Hilfs-Bibliothek (Disclaimer: Ich habe sie geschrieben). Sie möchten die Wrap Funktion.

• Dokumentation: https://godoc.org/github.com/eapache/channels#Wrap
• Code: https://github.com/eapache/channels/

Answer 2

Für alle anderen, dass in dieser Frage stolpert und will einige Inline-Code:

// 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) 
    } 
}