A port of the Rx functions to make Dart's Stream type even easier to use!