class Concurrent::Stream::Map(S, D, E, SC)
- Concurrent::Stream::Map(S, D, E, SC)
- Concurrent::Stream::SendRecv(D, D, D | E, SC)
- Concurrent::Stream::Base
- Reference
- Object
Defined in:
concurrent/stream.crConstructors
Instance methods inherited from class Concurrent::Stream::SendRecv(D, D, D | E, SC)
batch(size : Int32, *, flush_interval : Float | Nil = nil, flush_empty : Bool = false)
batch,
close : Nil
close,
errors(*, fibers : Int32 | Nil = nil, &block : Exception, E | 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