当子流之一发出时，Dart StreamZip 发出

Question

我有两个提供流的数据源（a 和 b）。新数据将独立添加到它们中。 现在我想创建一个流 (z)，它将这两个流合并为一个，从而组合元素。

因此，当“a”第一次发出时，“b”还没有值，应该不会发生任何事情（无论我是否必须实现它或者它是否集成在库中都没关系......）。当“b”首先发出时也是如此。

当两个流至少发出一次时，我希望“z”将这两个流彼此合并。这适用于 StreamZip。

但现在的问题是，如果“a”再次发出，但“b”没有发出，StreamZip 会等待，直到“b”再次发出，直到它自己（z）再次发出。 我猜这是设计使然，因为源代码显示了这种行为：

// taken from: stream_zip.dart, shortened for better readability
...

    void handleData(int index, T data) {
      dataCount++;
      // subscriptions has the length 2, as I have two input streams,
      // but dataCOunt is 1, as only one source stream emitted
      if (dataCount == subscriptions.length) {
        // handle the data
        // ...
      } else {
        // don't do anything
        subscriptions[index].pause();
      }
    }

有没有办法在不自己编写逻辑的情况下处理这个问题？我想使用 RxDart 是一种选择吗？ 或者我使用/解释了错误的东西？