class

Concurrent::Stream::Run(S, E)

Inherits Concurrent::Stream::Destination / Concurrent::Stream::ErrorHandling / Concurrent::Stream::Receive / Concurrent::Stream::Base / Reference / Object

Constructors

new(src_vch : Channel(S), src_ech : Channel(Tuple(Exception, E)), *, fibers : Int32, parent : Base, block : S -> _)
Source