我的建议沿着：

def mux[T](a: Source[T, Any], b: Source[T, Any])(cond: Int => Boolean): Source[T, Any] = {
  a.map((1, _)).merge(b.map((2, _)))
    .filter(t => cond(t._1))
    .map(_._2)
}

简单地说，它为每个源发出的元素附加一个标识符（这里是1、2，但可以是任何值），然后使用提供的cond函数进行过滤，只保留来自当前选定源的元素，然后Map回该元素。
我认为zip不是一个好主意，因为它 “当所有输入都有一个元素可用时发出”，也就是说，即使源A中有一个元素可用，而您实际上想切换到源A，zip也会等到B中有一个元素可用时才发出（ref）。
另一方面，merge将在任何源具有可用项时立即发出。

我不确定这是否是您所需要的，但您可以尝试以下操作：

def cond: Boolean = Random.nextBoolean()

val src1 = Source.fromIterator(() => LazyList.from(1).iterator)
val src2 = Source.fromIterator(() => LazyList.from(-1, -1).iterator)
val src3 = src1.zip(src2).map(pair => if (cond) pair._1 else pair._2)

src3.runForeach(println)

在一个run in Scastie中，输出开始于：

1
-2
3
4
-5
-6
7
-8
-9
10
...

如您所见，在本例中，我在两个流之间随机选择。