小编Dan*_*l K的帖子

有没有像RxJS那样的解决方案？ 是否可以在Rx中的不同线程上调用订阅者的OnNexts？

PS我的第一个天真的方法(在CoffeeScript中)明显失败了:

hObs = Rx.Observable.interval(35000)
    .startWith(-1)
    .select(moment().format("D MMMM, HH:mm:ss"))
    .publish()

hObs.subscribe((x)->console.log(x))
hObs.connect()
hObs.subscribe((x)->console.log(x, 1))
hObs.connect() 

第二个订阅在35秒间隔内不返回任何内容,依此类推