Instance methods inherited from class Concurrent::Stream::Base(Array(D))

batch(size : Int32) batch, close : Nil close, map(*, fibers : Int32? = nil, &block : T(D) -> U) forall U map, run(*, fibers : Int32? = nil, &block : T(D) -> _) run, select(*, fibers : Int32? = nil, &block : T(D) -> Bool) select, serial serial, tee(*, fibers : Int32? = nil, &block : T(D) -> _) tee, to_a(*args, **options)
to_a(*args, **options, &) to_a, wait(*args, **options)
wait(*args, **options, &) wait

Constructor methods inherited from class Concurrent::Stream::Base(Array(D))

new(*, fibers : Int32, dst_vch : Channel(T(D)), dst_ech : Channel(Exception)? = nil) new

Instance methods inherited from module Concurrent::Stream::Receive

handle_error(ex, src_vch, src_ech, dst_ech) handle_error