Fault-tolerant remote execution operators for the Reactive Extensions library