并行处理两个可观察的物品，并转换为一个可观察的

Question

我有两个可观察到的可观察值，如下所示

import monix.reactive.Observable
import scala.collection.immutable
val a: immutable.Seq[(String, String)] = (0 to 10).toList.map(x =>(s"left-$x", s"right-$x"))
val originalStream: Observable[(String, String)] = Observable.fromIterable(a)
val leftStream: Observable[String] = originalStream.map(_._1).map(println)
val rightStream: Observable[String] = originalStream.map(_._2).map(println)

现在，我如何运行左路和权利流行语，并将它们组合在一起以获得我可以订阅的新观察员？执行可观察的。

做leftStream.zip(rightStream)，应为两个流提供背压。

但是使用映射从OriginalStream创建左流和rentertream，这意味着OriginalStream中的一个元素将转到以下任何一个流中，而不是两者。