Port of the Reactive Extensions (RX) API to Dart