abstract class Concurrent::Stream::Destination(E)

• Concurrent::Stream::Destination(E)
• Concurrent::Stream::Base
• Reference
• Object

Overview

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

Included Modules

• Concurrent::Stream::ErrorHandling(E)
• Concurrent::Stream::Receive(E)

Direct Known Subclasses

• Concurrent::Stream::Run(S, E)
• Concurrent::Stream::Serial(T, E)

Defined in:

concurrent/stream.cr

Constructors

• .new(fibers, parent)

Instance Method Summary

• #close : Nil
• #detach(&block)

  Likely to be replaced with a Future or async shard later

  EXPERIMENTAL

• #detach

  Likely to be replaced with a Future or async shard later

  EXPERIMENTAL

• #wait(*args, **options)
• #wait(*args, **options, &)

Constructor Detail

Instance Method Detail