class Concurrent::Stream::Serial(T)

Included Modules

Defined in:



Instance Method Summary

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

def : Channel(T), src_ech : Channel(Exception)) #

[View source]

Instance Method Detail

def each(&) #
Description copied from module Enumerable(T)

Must yield this collection's elements to the block.

[View source]