Major Change: Support schedulers

Cumulocity-IoT / apama-rxepl

ReactiveX for Apama EPL Created by Global Presales.

Apache License 2.0

4 stars 2 forks source link

Open rpeach-sag opened 5 years ago

rpeach-sag commented 5 years ago

It would be nice to be able to configure the behaviour when handling very long synchronous lists, such that values are pulled rather than pushed.

Eg:

IObservable o := Observable.from([1,2,3, ..., 9999999,1000000]);
o.zip([o])
   .subscribe(...)