在 RxJava2 中实现滑动窗口

Question

我正在尝试在 RxJava2 中实现一个简单的滑动窗口功能，但努力做我想做的事。

我的目标是获取对象流，即

["a", "b", "c", "d", "e"]

并应用一个滑动窗口，它将返回与每个元素相邻的元素。

即导致：

["a", "b"]
["a", "b", "c"]
["b", "c", "d"]
["c", "d", "e"]
["d", "e"].

I.E.

a----------------b----------------c----------------d----------------e
↓                ↓                ↓                ↓                ↓
↓                ↓                ↓                ↓                ↓
↓                ↓                ↓                ↓                ↓
↓                ↓                ↓                ↓                ↓
["a", "b"]       ["a", "b", "c"]  ["b", "c", "d"]  ["c", "d", "e"]  ["d", "e"]

我似乎无法弄清楚如何做到这一点。 Google Groups 的帖子似乎走在了正确的轨道上，但并没有完全得到我需要的结果： https://groups.google.com/forum/#!topic/rxjava/k-U5BijXinU

有什么想法吗？

Answer 1

也许正如@jrook 所说，这不是标准窗口的最佳选择。数组大小本身并不足以知道您在元素的哪一侧，所以我将其包装在一个简单的值类中。

这是我采用的解决方案。对于较大的流来说，这绝对不是一个好的解决方案，因为它会阻止首先读取整个 observable，这对于某些用例显然可能不太好（在我的情况下，没关系）。

 public static <R> ObservableTransformer<R, AdjacentPairing<R>> pairWithAdjacents() {
    return upstream -> upstream
        .toList()
        .flatMapObservable(list -> {
          ArrayList<AdjacentPairing<R>> pairings = new ArrayList<>(list.size());
          for (int i = 0; i < list.size(); i++) {
            pairings.add(AdjacentPairing.from(
                i == 0 ? null : list.get(i - 1),
                list.get(i),
                i == list.size() -1 ? null : list.get(i + 1)));
          }
          return Observable.fromIterable(pairings);
        });
  }

  @AutoValue
  public static abstract class AdjacentPairing<T> {
    @Nullable
    public abstract T getPrevious();
    public abstract T getElement();
    @Nullable
    public abstract T getNext();

    public static <T> AdjacentPairing<T> from(@Nullable T previous, T element, @Nullable T next){
      return new AutoValue_RxUtils_AdjacentPairing<>(previous, element, next);
    }
  }

Answer 2

根据您是否希望 observable 发出 List<Item> 或 Observable<Item> 您可以使用 buffer() 或 window() 运算符。解决方案不是那么干净，但非常简单：

Observable.fromArray("a", "b", "c", "d", "e")
        .startWith("")
        .buffer(3, 1)
        .map(strings -> {
            strings.remove("");
            return strings;
        })
        .filter(strings -> strings.size() > 1)

返回

["a", "b"]
["a", "b", "c"]
["b", "c", "d"]
["c", "d", "e"]
["d", "e"]