system.reactive - Why I am getting only one item out of this Observable? -
i have cold observable static number of items, needed time delay between each item, have combined iobservable got through observable.timer
. using zip
.
var ob1 = observable.range(1, 100); var ob2 = observable.timer(timespan.fromseconds(1.0)); var myobservable = observable.zip(ob1, ob2, (a, b) => b); myobservable.subscribe(a => console.writeline("item encountered")); ///allow enough time timer observable give multiple ticks thread.sleep(3000);
but output prints "item encountered" once. missing ?
to confirm commentary, observable.interval
way go single argument - , has been!
Comments
Post a Comment