class

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

Inherits Concurrent::Stream::SendRecv / Concurrent::Stream::Receive / Concurrent::Stream::Base / Reference / Object

Constructors

new(src_vch : Channel(SV), src_ech : Channel(Tuple(Exception, E)), *, batch_size : Int32, parent, flush_interval, flush_empty : Bool)
Source