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

Popular posts from this blog

google api - Incomplete response from Gmail API threads.list -

Installing Android SQLite Asset Helper -

Qt Creator - Searching files with Locator including folder -