class Concurrent::Stream::Errors(B, S)
- Concurrent::Stream::Errors(B, S)
- Concurrent::Stream::SendRecv(B, S, S, Nil)
- Concurrent::Stream::Base
- Reference
- Object
Included Modules
Defined in:
concurrent/stream.crConstructors
Instance methods inherited from class Concurrent::Stream::SendRecv(B, S, S, Nil)
batch(size : Int32, *, flush_interval : Float | Nil = nil, flush_empty : Bool = false)
batch,
close : Nil
close,
errors(*, fibers : Int32 | Nil = nil, &block : Exception, E -> Nil)
errors,
map(*, fibers : Int32 | Nil = nil, &block : V -> U) forall U
map,
run(*, fibers : Int32 | Nil = nil, &block : V -> _)
run,
scope(&block : -> U) forall U
scope,
select(*, fibers : Int32 | Nil = nil, &block : V -> Bool)
select,
serial
serial,
tee(*, fibers : Int32 | Nil = nil, &block : V -> _)
tee,
to_a(*args, **options)to_a(*args, **options, &) to_a