Module: FiberStream

Defined in:

lib/fiber_stream.rb,
lib/fiber_stream/flow.rb,
lib/fiber_stream/pull.rb,
lib/fiber_stream/pull.rb,
lib/fiber_stream/sink.rb,
lib/fiber_stream/errors.rb,
lib/fiber_stream/source.rb,
lib/fiber_stream/version.rb,
lib/fiber_stream/pipeline.rb,
lib/fiber_stream/pull/map.rb,
lib/fiber_stream/pull/each.rb,
lib/fiber_stream/pull/take.rb,
lib/fiber_stream/pull/lines.rb,
lib/fiber_stream/pull/select.rb,
lib/fiber_stream/ractor_port.rb,
lib/fiber_stream/pull/io_source.rb,
lib/fiber_stream/running_pipeline.rb,
lib/fiber_stream/pull/async_boundary.rb,
lib/fiber_stream/pull/buffer_boundary.rb,
lib/fiber_stream/pull/ractor_port_source.rb,
lib/fiber_stream/pull/ractor_map_boundary.rb,
lib/fiber_stream/pull/parallel_map_boundary.rb

Defined Under Namespace

Modules: RactorPort Classes: Flow, FrameTooLongError, Pipeline, PipelineCancelledError, RactorMapError, RactorPortSourceError, RunningPipeline, SchedulerRequiredError, Sink, Source

Constant Summary

VERSION =

"0.1.0"