rxjs pairwise 发出重复值

Question

我正在尝试为垂直和水平滚动方向创建两个可观察的滚动事件。

我尝试使用 pairwise() 和 bufferCount(2,1) 运算符从水平滚动事件中过滤垂直滚动事件，但问题是获取 prev.scrollTop 和 curr.scrollTop 的重复值

import { Component, ViewChild, AfterViewInit, ElementRef } from '@angular/core';
import { fromEvent } from 'rxjs';
import { pairwise, tap, filter } from 'rxjs/operators';

@Component({
  selector: 'my-app',
  templateUrl: './app.component.html',
  styleUrls: ['./app.component.css']
})
export class AppComponent implements AfterViewInit {

  @ViewChild('scrollable', {static: false}) scrollable: ElementRef;


  ngAfterViewInit() {

    fromEvent(this.scrollable.nativeElement, 'scroll').pipe(
      pairwise(),
      tap(([prev, curr]) => console.log(prev.target.scrollTop, curr.target.scrollTop)),
      filter(([prev, curr]) => prev.target.scrollTop !== curr.target.scrollTop),
      tap((e) => console.log(e)) // <=    Never reached
    ).subscribe();

  }

}

有什么想法吗？

stackblitz reproduction

Answer 1

那是因为您将始终引用同一对象的 nativeElement 配对。所以基本上你必须pluck你想要的原始值。

  fromEvent(this.scrollable.nativeElement, 'scroll').pipe(
      pluck('target','scrollTop'),
      pairwise(),
      tap(([prev, curr]) => console.log(prev,curr)),
      filter(([prev, curr]) => prev!== curr),
      tap((e) => console.log(e)) // <=    Never reached
    ).subscribe();

rxjs pairwise 发出重复值

rxjs pairwise is emitting duplicate values

rxjs

angular

pairwise