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!
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
- Download
- API doc
- Bug Tracker
- Follow @theburningmonk on Twitter for updates