Golang: Posso lanciare all'interfaccia chan {}

Question

Sto cercando di scrivere un wrapper di uso generale per gli abbonamenti, qualcosa come:

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

Supponiamo che ci sia una libreria che voglio usare, che ha un metodo sottoscrivere in esso, ma che utilizza un chan library.Object. Vorrei poter fare qualcosa del tipo:

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

Attualmente, non credo che un tale cast sia possibile. E non voglio modificare la libreria sottostante, dal momento che il wrapper dovrebbe essere agnostico alle implementazioni della libreria.

Ho visto Is there a way to cast Structs for sending over a channel, ma in tal caso l'applicazione può essere modificata in base alle esigenze. Qui, non può. È possibile? C'è un modo migliore?

Una soluzione è passare in un canale di uso generale in Iscriviti e attendere indefinitamente su chan library.Object e attivare tutto ciò che viene visualizzato sul mio canale generale, ma non mi è piaciuto particolarmente dover introdurre un altro canale solo per spostarsi il cast del tipo.

Answer 1

No, non puoi farlo solo con un cast. Devi usare un canale extra, come hai già considerato. Fortunatamente, esiste già una libreria di supporto (disclaimer: l'ho scritto). Vuoi la funzione Wrap.

• Documentazione: https://godoc.org/github.com/eapache/channels#Wrap
• Codice: https://github.com/eapache/channels/

Answer 2

Per chiunque altro che inciampa su questo tema e vuole un po 'di codice 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) 
    } 
}