class Concurrent::Stream::Serial(T)
- Concurrent::Stream::Serial(T)
- 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
Constructor Detail
Instance Method Detail
def each(&)
#
Description copied from module Enumerable(T)
Must yield this collection's elements to the block.