Versions in this module Expand all Collapse all v0 v0.0.2 May 26, 2020 Changes in this version + func Bridge(done <-chan struct{}, chanStream <-chan <-chan interface{}) <-chan interface + func Duplicate(done <-chan struct{}, in <-chan interface{}) (<-chan interface{}, <-chan interface{}) + func FanIn(done <-chan struct{}, channels ...<-chan interface{}) <-chan interface + func FanOut(done <-chan struct{}, ...) []<-chan interface + func Or(dones ...<-chan struct{}) <-chan struct + func OrDone(done <-chan struct{}, stream <-chan interface{}) <-chan interface + func Repeat(done <-chan struct{}, fn func() interface{}) <-chan interface
Go to main page