class Concurrent::Stream::Tee(S)

Defined in:

concurrent/stream.cr

Constructors

Instance methods inherited from class Concurrent::Stream::Base(S)

batch(size : Int32) batch, close : Nil close, map(*, fibers : Int32? = nil, &block : T -> U) forall U map, run(*, fibers : Int32? = nil, &block : T -> _) run, select(*, fibers : Int32? = nil, &block : T -> Bool) select, serial serial, tee(*, fibers : Int32? = nil, &block : T -> _) 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(S)

new(*, fibers : Int32, dst_vch : Channel(T), 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), *, fibers : Int32, &block : S -> _) #

[View source]