RxJava：可观察到的冷热结合

Question

我有两个可观察到的。它们都是可观察的类型

一种是冷的，称为初始值可观察（initialValueObservable），它通过可观察（Observable）从项目列表中发出。from（）。

另一个是名为“valueUpdateObservable”的热门主题，它是一个发布主题，在出现新项目时通知订阅者。

在客户端中，我想同时订阅这两个，因此我从firalValue观察和value Update观察发布的更新中获取初始值。我最初的方法是合并它们，但我认为这不起作用，因为初始值值观察将在完成上发送，此时值更新观察发出的新项目不会到达。




Answer 1

如果有人来找这个，这里有一个例子

Observable.concat(
    coldObservable.doOnComplete{ () -> Log.d(TAG, "cold observable completed"); },
    hotObservable.doOnComplete{ () -> Log.d(TAG, "hot observable completed") }
.subscribe()

将记录所有coldObservable的值，然后是“cold observable completed”，然后是所有hotObvservable的值。假设“hot observable completed”类似于没有完成状态的单击侦听器，则不会记录它

Answer 2

当您进行合并时，仅当所有源观测值（在本例中为两者）都已完成时，才会发送onComplete。

以（c#Rx.NET）代码为例：

Observable
    .Return(42L)
    .Merge(Observable.Interval(TimeSpan.FromSeconds(1.0)).Take(3))
    .Subscribe(x => Console.WriteLine(x));

它产生：

42
0
1
2

如果RxJava做了什么不同的事情，我会感到惊讶。