ribs_rill
Classes
| Class | Description |
|---|---|
| ChannelClosed | |
| Chunk<O> | A strictly strict, immutable sequence of values, optimized for indexed based access and efficient concatenation. |
| CompositeFailure | |
| Lease | |
| OverflowStrategy | |
| Pipes | |
| 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> | |
| RillCompile<O> | |
| RillDecoder<A> | |
| RillEncoder<A> | |
| RillResourceCompile<O> | |
| Scope | |
| Signal<A> | |
| SignallingRef<A> | |
| Topic<A> | |
| TopicClosed | |
| ToPull<O> | Provides high-level inspection methods for a Rills's underlying Pull. |
Mixins
| Mixin | Description |
|---|---|
| Channel<A> |
Extensions
| Extension | on | Description |
|---|---|---|
| ChunkByteOps | Chunk<int> | |
| ParJoinOps<O> | Rill<Rill<O>> | |
| PullFlattenOps<O, R> | Pull<O, Pull<O, R>> | |
| 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>> | |
| RillBooleanOps | Rill<bool> | |
| RillChunkOps<A> | Rill<Chunk<A>> | |
| RillCompilerIntOps | RillCompile<int> | |
| RillCompilerStringOps | RillCompile<String> | |
| RillFlattenOps<O> | Rill<Rill<O>> | |
| RillNeverOps | Rill<Never> | Operations only available on a Rill that emits no elements — Rill<Never>. |
| RillOptionOps<A> | Rill<Option<A>> | |
| 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> | |
| ToDartStreamOps<O> | Rill<O> |
Functions
| Function | Description |
|---|---|
| chunk<O> |
Typedefs
| Typedef | Description |
|---|---|
| MergeState | |
| Pipe<I, O> |