class

Concurrent::Stream::Source(T, E)

Inherits Concurrent::Stream::SendRecv / Concurrent::Stream::Receive / Concurrent::Stream::Base / Reference / Object

Input from an Enumerable or Channel.

Constructors

new(*, fibers : Int32, dst_vch : Channel(T), dst_ech : Channel(Tuple(Exception, E)) | Nil = nil)
Source