stream_ext
This is a port of the Rx functions for working with Dart's Stream
type, which already has the basic set of Rx APIs such as select
and where
.
This library adds the more 'exotic' Rx functions such as delay
, buffer
, scan
, throttle
, zip
, merge
, etc. to help make working with Dart's Stream
type even easier!
Getting Started
To get up to speed with stream_ext:
- have a look at the Getting Started document
- the wiki also contains details (including marble diagrams) for each of the functions
- the example directory also contains more useful/meaningful usages for each of the functions
Feedbacks
I would love to know what you think of this project, and where it might be improved. Please feel free to get in touch if you have any questions about this project.