A port of the Reactive Extensions framework to D