class Concurrent::Stream::Serial(T)
- Concurrent::Stream::Serial(T)
- Concurrent::Stream::Base
- Reference
- Object
Included Modules
- Concurrent::Stream::Receive
- Enumerable(T)
Defined in:
concurrent/stream.crConstructors
Instance Method Summary
-
#each(&)
Must yield this collection's elements to the block.
Instance methods inherited from module Concurrent::Stream::Receive
handle_error(ex, src_vch, src_ech, dst_ech)
handle_error
Instance methods inherited from module Enumerable(T)
parallel(*, fibers : Int32 = System.cpu_count.to_i)
parallel
Instance methods inherited from class Concurrent::Stream::Base
unhandled_error(ex : Exception) : Nil
unhandled_error,
wait(*args, **options)wait(*args, **options, &) wait
Constructor methods inherited from class Concurrent::Stream::Base
new(*, parent)
new
Constructor Detail
Instance Method Detail
def each(&)
#
Description copied from module Enumerable(T)
Must yield this collection's elements to the block.