commit | 20562266cc594712b0b988de3d3cb0628830ab87 | [log] [tgz] |
---|---|---|
author | Natalie Weizenbaum <nweiz@google.com> | Mon Jan 09 22:39:45 2017 |
committer | GitHub <noreply@github.com> | Mon Jan 09 22:39:45 2017 |
tree | 22e69192526ae5487b77551143ff5fd824514795 | |
parent | a6034c9bb6d91520f19be65f0daffccb7f1838c1 [diff] |
Add StreamQueue.startTransactions(). (#9) This is important for advanced pull-based stream manipulation. It allows users to express logic of the form "consume the next events if they match this predicate".
Contains utility classes in the style of dart:async
to work with asynchronous computations.
The StreamZip
class can combine several streams of events into a single stream of tuples of events.
The package introduces a Result
class that can hold either a value or an error. It allows capturing an asynchronous computation which can give either a value or an error, into an asynchronous computation that always gives a Result
value, where errors can be treated as data. It also allows releasing the Result
back into an asynchronous computation.