class

Concurrent::Stream::Destination(E)

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

Terminates the stream Always call #wait or #detach on this object. Not calling #wait or #detach is undefined.

Constructors

new(fibers, parent)

Instance methods

close

detach

Likely to be replaced with a Future or async shard later

detach

Likely to be replaced with a Future or async shard later

wait(*args, **options)

wait(*args, **options, &)