class Concurrent::Stream::Serial(T, E)

Included Modules

Defined in:

concurrent/stream.cr

Constructors

Instance Method Summary

Instance methods inherited from module Enumerable(T)

parallel(*, fibers : Int32 = System.cpu_count.to_i) parallel, serial : self serial

Instance methods inherited from class Concurrent::Stream::Destination(E)

close : Nil close, detach(&block)
detach detach, wait(*args, **options)
wait(*args, **options, &) wait

Constructor methods inherited from class Concurrent::Stream::Destination(E)

new(fibers, parent) new

Instance methods inherited from class Concurrent::Stream::Base

close : Nil close

Constructor methods inherited from class Concurrent::Stream::Base

new(*, fibers : Int32, parent : Concurrent::Stream::Base | Nil) new

Constructor Detail

def self.new(src_vch : Channel(T), src_ech : Channel(Tuple(Exception, E)), parent) #

[View source]

Instance Method Detail

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

Must yield this collection's elements to the block.


[View source]