如何解决RxJS范围重叠

How to solve RxJS range overlap?

本文关键字：RxJS 范围 重叠 解决 何解决      更新时间：2023-09-26

假设我有两个名为source1和source2的可观测序列。我想将source2与source1匹配，这样source2就不会完全重叠source1:

// source1 = Rx.Observalble.range(...)
// source2 = Rx.Observable.range(...)
           |.............|            // `source1` range
      |--------|                      // false: `source2` is overlapped
                      |--------|      // false: `source2` is overlapped
              |--------|              // false: `source2` is overlapped
//|-------|                           // true: `source2` is not overlapped
//                        |--------|  // true: `source2` is not overlapped

我的解决方案是使用Rx.Observable#first和Rx.Observable#last如下：

source1 = Rx.Observable.range(100, 50)
source2 = Rx.Observable.range(150, 10)
pred1 = source1.first().zip(source2.last(), (a, b) => a >= b)
pred2 = source1.last().zip(source2.first(), (a, b) => a <= b)
// Have to use #combineLatest to get it done, don't know why 
// #zip doesnt work. Uncomment the line below to check
// pred1.zip(pred2, (a, b) => a || b).subscribe(x => console.log(x))
pred1.combineLatest(pred2, (a, b) => a || b).subscribe(x => console.log(x))

我期待看到使用其他运算符（如#reduce、#scan、#flatMap、#concatMap或#filter）的解决方案。

原因是，上面的例子只是比较了两个范围。如果我有一个范围数组需要检查它们是否相互重叠，该怎么办。考虑一个reducer在这种情况下会有所帮助。

// `array_of_range` could be an array of observable sequences
let source = Rx.Observalbe.fromArray(array_of_range)
source.scan((prev, curr) => {
  // Do magic here
}, false)
      .subscribe(x => console.log(x)) //=> Check if any two ranges in the `source` are overlapped or not

如果范围重叠，如何将这些范围transform转换为最佳的较小新范围，使它们不会相互重叠。我知道这不是一个微不足道的答案，所以任何建议都很感激！

更新01:多亏了@joneshf，第一个问题可以通过以下方式解决：

Rx.Observable.merge(
  Rx.Observable.range(0, 10),
  Rx.Observable.range(11, 20),
  Rx.Observable.range(21, 25)
  )
  .scan(({intersected, set}, n) => ({intersected: set.has(n), set: set.add(n)}), 
  {intersected: false, set: new Set()}
  )
  .pluck('intersected')
  .reduce((prev, curr) => prev || curr)
  .subscribe(x => x ? ‘There was an intersection’ : ‘No intersection’)

欢迎进一步讨论！

您可以按索引分组（使用zip）

zip(range(1, 10), range(5, 10), range(10, 10)).subscribe(z => {
  console.log(z);
});
//=> [ 1 , 5 , 10 ]
//=> [ 2 , 6 , 11 ]
//=> [ 3 , 7 , 12 ]
//=> [ 4 , 8 , 13 ]
//=> [ 5 , 9 , 14 ]
//=> [ 6 , 10, 15 ]
//=> [ 7 , 11, 16 ]
//=> [ 8 , 12, 17 ]
//=> [ 9 , 13, 18 ]
//=> [ 10, 14, 19 ]

然后，您可以重建每个范围，如果且仅当其编号以前从未见过：

主集
输入1st rg2nd rg3rd rg
[1,5,10][1][5][10]设置｛1 5 10｝
[2，6，11][1，2][5，6][10，11]设置｛1 2 5 6 10 11｝
[3，7，12][1，2，3][5，6，7][10，11，12]设置｛1 2 3 5 6 7 10 11 12｝
相关文章：