c# – 如何合并两个Observable,以便在任何Observable完成时结果

发布时间：2020-12-15 17:42:53 所属栏目：百科来源：网络整理

导读：我有这个代码： var s1 = new SubjectUnit();var s2 = new SubjectUnit();var ss = s1.Merge(s2).Finally(() = Console.WriteLine("Finished!"));ss.Subscribe(_ = Console.WriteLine("Next"));s1.OnNext(new Unit());s2.OnNext(new Unit());s1.OnCompleted(

我有这个代码：

var s1 = new Subject<Unit>();
var s2 = new Subject<Unit>();
var ss = s1.Merge(s2).Finally(() => Console.WriteLine("Finished!"));

ss.Subscribe(_ => Console.WriteLine("Next"));

s1.OnNext(new Unit());
s2.OnNext(new Unit());
s1.OnCompleted(); // I wish ss finished here.
s2.OnCompleted(); // Yet it does so here. =(

我已经使用OnError(new OperationCanceledException())解决了我的问题,但我想要一个更好的解决方案(必须有一个组合器吗？).

解决方法

或者这个,这也很整洁：

public static class Ext
{
    public static IObservable<T> MergeWithCompleteOnEither<T>(this IObservable<T> source,IObservable<T> right)
    {
        return Observable.CreateWithDisposable<T>(obs =>
        {
            var compositeDisposable = new CompositeDisposable();
            var subject = new Subject<T>();

            compositeDisposable.Add(subject.Subscribe(obs));
            compositeDisposable.Add(source.Subscribe(subject));
            compositeDisposable.Add(right.Subscribe(subject));


            return compositeDisposable;

        });     
    }
}

这使用了一个主题,它将确保只有一个OnCompleted被推送到CreateWithDisposable()中的观察者;

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!