class Concurrent::Stream::Source(T)
- Concurrent::Stream::Source(T)
- Concurrent::Stream::SendRecv(T, Nil)
- Concurrent::Stream::Base
- Reference
- Object
Overview
Input from an Enumerable or Channel.
Defined in:
concurrent/stream.crConstructors
Instance methods inherited from class Concurrent::Stream::SendRecv(T, Nil)
batch(size : Int32, *, flush_interval : Float? = nil, flush_empty : Bool = false)
batch,
close : Nil
close,
map(*, fibers : Int32? = nil, &block : T -> U) forall U
map,
run(*, fibers : Int32? = nil, &block : T -> _)
run,
scope(&block : -> U) forall U
scope,
select(*, fibers : Int32? = nil, &block : T -> Bool)
select,
serial
serial,
tee(*, fibers : Int32? = nil, &block : T -> _)
tee,
to_a(*args, **options)to_a(*args, **options, &) to_a
Constructor methods inherited from class Concurrent::Stream::SendRecv(T, Nil)
new(*, fibers : Int32, dst_vch : Channel(T), dst_ech : Channel(Exception)? = nil, parent)
new
Instance methods inherited from module Concurrent::Stream::Receive
handle_error(ex, src_vch, src_ech, dst_ech)
handle_error
Instance methods inherited from class Concurrent::Stream::Base
unhandled_error(ex : Exception) : Nil
unhandled_error,
wait(*args, **options)wait(*args, **options, &) wait