c# - 从数组在 Rx 中创建热可观察对象

Question

我该怎么做？

我有一个代码可以:

new int[]{1,2,3}.ToObservable().Subscribe(myObserver);

问题是第一次调用是一个冷的可观察对象，因此在这样的另一个调用中:

new int[]{4,5,6}.ToObservable().Subscribe(myObserver);

myObserver 根本不会触发 onNext。显然是因为第一个调用发布了 1,2,3, END。我不希望 observable 调用“END”，因为我想稍后继续订阅。有没有一种功能可以轻松地为我做到这一点？

Answer 1

你需要做这样的事情:

new int[] { 1, 2, 3, }
    .ToObservable()
    .Concat(Observable.Never<int>())
    .Subscribe(myObserver); 

new int[] { 4, 5, 6, }
    .ToObservable()
    .Concat(Observable.Never<int>())
    .Subscribe(myObserver);

关键是做一个.Concat(Observable.Never<int>())在 observable 上以防止它永远结束。