class Concurrent::Stream::Batch(S, D)

Defined in:

concurrent/stream.cr

Constructors

Instance methods inherited from class Concurrent::Stream::Base(Array(D))

batch(size : Int32) batch, close : Nil close, map(*, fibers : Int32? = nil, &block : T(D) -> U) forall U map, run(*, fibers : Int32? = nil, &block : T(D) -> _) run, select(*, fibers : Int32? = nil, &block : T(D) -> Bool) select, serial serial, tee(*, fibers : Int32? = nil, &block : T(D) -> _) tee, to_a(*args, **options)
to_a(*args, **options, &)
to_a
, wait(*args, **options)
wait(*args, **options, &)
wait

Constructor methods inherited from class Concurrent::Stream::Base(Array(D))

new(*, fibers : Int32, dst_vch : Channel(T(D)), dst_ech : Channel(Exception)? = nil) new

Instance methods inherited from module Concurrent::Stream::Receive

handle_error(ex, src_vch, src_ech, dst_ech) handle_error

Constructor Detail

def self.new(src_vch : Channel(S), src_ech : Channel(Exception), *, batch_size : Int32) #

[View source]