abstract class Concurrent::Stream::SendRecv(T, SC)

• Concurrent::Stream::SendRecv(T, SC)
• Concurrent::Stream::Base
• Reference
• Object

Overview

#map, #select, #run and #tee run in a fiber pool. #batch runs in a single fiber All other methods "join" in the calling fiber.

Exceptions are raised in #each when joined.

TODO better error handling.

Included Modules

• Concurrent::Stream::Receive

Direct Known Subclasses

• Concurrent::Stream::Batch(S, D)
• Concurrent::Stream::Map(S, D, SC)
• Concurrent::Stream::Run(S)
• Concurrent::Stream::Select(S)
• Concurrent::Stream::Source(T)
• Concurrent::Stream::Tee(S)

Defined in:

concurrent/stream.cr

Constructors

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

Instance Method Summary

• #batch(size : Int32, *, flush_interval : Float? = nil, flush_empty : Bool = false)

  Groups results in to chunks up to the given size.

• #close : Nil
• #map(*, fibers : Int32? = nil, &block : T -> U) forall U

  Parallel map.

• #run(*, fibers : Int32? = nil, &block : T -> _)

  Parallel run.

• #scope(&block : -> U) forall U

  Further processing is evaluated within the scope of the returned object.

• #select(*, fibers : Int32? = nil, &block : T -> Bool)

  Parallel select.

• #serial
• #tee(*, fibers : Int32? = nil, &block : T -> _)

  Parallel tee.

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

Constructor Detail

Instance Method Detail