class Concurrent::Stream::Batch(SV, DV, E)

Defined in:

concurrent/stream.cr

Constructors

Instance methods inherited from class Concurrent::Stream::SendRecv(Array(DV), Array(DV), Array(DV) | E, Nil)

batch(size : Int32, *, flush_interval : Float | Nil = nil, flush_empty : Bool = false) batch, close : Nil close, errors(*, fibers : Int32 | Nil = nil, &block : Exception, E(DV) | E -> Nil) errors, map(*, fibers : Int32 | Nil = nil, &block : V(DV) -> U) forall U map, run(*, fibers : Int32 | Nil = nil, &block : V(DV) -> _) run, scope(&block : -> U) forall U scope, select(*, fibers : Int32 | Nil = nil, &block : V(DV) -> Bool) select, serial serial, tee(*, fibers : Int32 | Nil = nil, &block : V(DV) -> _) tee, to_a(*args, **options)
to_a(*args, **options, &) to_a

Constructor methods inherited from class Concurrent::Stream::SendRecv(Array(DV), Array(DV), Array(DV) | E, Nil)

new(*, fibers : Int32, dst_vch : Channel(V(DV)), dst_ech : Channel(Tuple(Exception, E(DV) | E)) | Nil = nil, 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(SV), src_ech : Channel(Tuple(Exception, E)), *, batch_size : Int32, parent, flush_interval, flush_empty : Bool) #

[View source]