class Concurrent::Stream::Serial(T)

Included Modules

Defined in:

concurrent/stream.cr

Constructors

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 self.new(src_vch : 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]