c# 从 IEnumerable<IObservable<string>> 到 IObservable<string> 的响应式扩展

Question

我想使用响应式扩展来编写扩展方法

public static IObservable<string> ToString(
  this IEnumerable<IObservable<string>> collection,
  string start,
  string separator,
  string stop)
  {

  }

它产生一个字符串流，反映作为参数传递的流集合的最新内容。我还提供了一个起始字符串、一个分隔符和一个停止字符串以用于格式化。

当所有 observables 至少触发一次时，我想跟踪字符串表示，因为不同的 observables 触发更新。

例如，假设 start 是 "{"，separator 是 ";"，stop 是 "}"，那么集合中有 3 个 observables 都首先触发了 "0"，我想要 "{0; 0;0}" 是结果 observable 生成的初始字符串。

现在假设集合的第一个 observable 推送“1”，我希望生成的下一个字符串是“{1;0;0}”等等。

已经谢谢你的回答了。

Answer 1

您在此处描述的内容与CombineLatest 非常相似。请尝试以下操作：

public static IObservable<string> ToString(this IEnumerable<IObservable<string>> observables, string start, string separator, string stop)
{
    return observables.CombineLatest()
                      .Select(values =>
                      {
                          var sb = new StringBuilder(start);
                          var first = true;

                          foreach (var value in values)
                          {
                              if (first)
                                  first = false;
                              else
                                  sb.Append(separator);

                              sb.Append(value);
                          }

                          sb.Append(stop);
                          return sb.ToString();
                      });
}