class Concurrent::Stream::Run(S, E)

Defined in:

concurrent/stream.cr

Constructors

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(S), src_ech : Channel(Tuple(Exception, E)), *, fibers : Int32, parent : Base, block : S -> _) #

[View source]