A port of the Rx functions to make Dart's Stream type even easier to use! - View it on GitHub