Init() bool //?? do we want this? Run runs the operation of the stream. It should never return before all the goroutines it started have quit It should return in 3 cases: i) on error (returning the error) ii) on soft close (Its input has closed the channel, return nil) iii) on hard close (Stop was
()
source not stored for this graph (policy: none)
nothing calls this directly
no outgoing calls
no test coverage detected