ribs_rill
Classes
| Class | Description |
|---|---|
| ChannelClosed | Sentinel value returned when an operation is attempted on a closed Channel. |
| Chunk<O> | A strict, immutable sequence of values, optimized for index-based access and efficient concatenation. |
| CompositeFailure | Aggregates two or more concurrent errors into a single throwable value. |
| Lease | A hold on a Scope that defers its closure until the lease is released. |
| OverflowStrategy | Controls how a Rill.fromStream buffer behaves when it is full. |
| Pipes | Namespace for built-in Rill transformation pipelines. |
| Pull<O, R> | A Pull describes a process that can emit outputs of type O, evaluate effects of type IO, and eventually return a result of type R. |
| Rill<O> | A lazy, effectful, chunked stream of values of type O. |
| RillCompile<O> | Terminal operations for a Rill that run the stream and produce an IO. |
| RillDecoder<A> | A streaming binary decoder that drives a Decoder over a Rill of BitVectors, emitting decoded values as they become available. |
| RillEncoder<A> | A streaming binary encoder that applies an Encoder to each element of a Rill, emitting BitVector values. |
| RillResourceCompile<O> | Terminal operations for a Rill that expose results as Resource values. |
| Scope | Tracks resource finalizers for a subtree of a Pull computation. |
| Signal<A> | A read-only view of a value that can be observed over time. |
| SignallingRef<A> | A mutable, observable reference — a Ref that also acts as a Signal. |
| Topic<A> | A publish-subscribe hub for concurrent streams. |
| TopicClosed | Sentinel value returned when an operation is attempted on a closed Topic. |
| ToPull<O> | Provides high-level inspection methods for a Rills's underlying Pull. |
Mixins
| Mixin | Description |
|---|---|
| Channel<A> | A concurrent channel that supports sending and receiving values across fibers, with configurable back-pressure. |
Extensions
| Extension | on | Description |
|---|---|---|
| ChunkByteOps | Chunk<int> | Byte-oriented operations for Chunk<int>. |
| ParJoinOps<O> | Rill<Rill<O>> | Concurrent fan-in operations on a Rill of Rills. |
| PullFlattenOps<O, R> | Pull<O, Pull<O, R>> | Flattening operation for a Pull whose result is itself a Pull. |
| PullOps<O> | Pull<O, Unit> | Operations available ONLY when the result type is Unit. This ensures we can only inspect a "streaming" pull, not a calculated result. |
| RethrowOps<A> | Rill<Either<Object, A>> | Operations on a Rill of Either values. |
| RillBooleanOps | Rill<bool> | Operations on a Rill of booleans. |
| RillChunkOps<A> | Rill<Chunk<A>> | Operations on a Rill of Chunks. |
| RillCompilerIntOps | RillCompile<int> | Byte-stream compile terminals. |
| RillCompilerStringOps | RillCompile<String> | String-specific compile terminals. |
| RillFlattenOps<O> | Rill<Rill<O>> | Operations on a Rill of Rills. |
| RillNeverOps | Rill<Never> | Operations only available on a Rill that emits no elements — Rill<Never>. |
| RillOptionOps<A> | Rill<Option<A>> | Operations on a Rill of Options. |
| RillTuple2Ops<T1, T2> | Rill<Record> | Provides additional functions on a Rill of a 2 element tuple. |
| RillTuple3Ops<T1, T2, T3> | Rill<Record> | Provides additional functions on a Rill of a 3 element tuple. |
| RillTuple4Ops<T1, T2, T3, T4> | Rill<Record> | Provides additional functions on a Rill of a 4 element tuple. |
| RillTuple5Ops<T1, T2, T3, T4, T5> | Rill<Record> | Provides additional functions on a Rill of a 5 element tuple. |
| SignalMapOps<A> | Signal<A> | Functor operations for Signal. |
| ToDartStreamOps<O> | Rill<O> | Interop extension for converting a Rill to a Dart Stream. |
Functions
| Function | Description |
|---|---|
| chunk<O> | Convenience constructor — creates a Chunk from any Iterable. |
Typedefs
| Typedef | Description |
|---|---|
| Pipe<I, O> | A function that transforms a Rill<I> into a Rill<O>. |