如何确保不连接数组中的重复对象？

Question

我正在学习 Reactive Programming 使用 RxJs 并且需要一些帮助来找到适合这种情况的最佳操作员。我正在开发一个angular 4 应用程序并使用此方法：

  ngAfterViewInit() {
     this.returnUsers();
  }

  returnUsers() : void {
    this.userService.ListUsers(this.token)
        .subscribe(response => {
            this.token = response.token;
            this.users = this.users.concat(response.users);
        });
  }

  scrollDown() {
    this.returnUsers();
  }

功能还可以，问题是如果用户滚动太快，我发送到服务器的令牌是相同的，所以我连接重复的对象。我想知道如何处理它的最佳方法。我尝试使用.filter 运算符，也只连接不重复的对象，但我仍在访问服务器。

编辑： 我正在使用angular2-infinite-scroll

Answer 1

您是否在每个滚动事件上调用scrollDown() 方法？

如果是这样，那么您正在为每个滚动事件进行新订阅，这可能不是您想要的。
我认为您需要使用 Subject 实例并在每个滚动事件上推送一个值。然后你可以使用debounceTime(100) 来丢弃到达太快并且只有一个订阅的发射。

类似这样的东西（显然我没有测试这段代码，但我希望你能明白这一点）。

private subject$ = new Subject();

constructor() {
    this.subject$
        .debounceTime(100)
        .concatMap(() => this.userService.ListUsers(this.token))
        .subscribe(response => {
            this.token = response.token;
            this.users = this.users.concat(response.users);
        });
    });
}

scrollDown() {
    this.subject$.next();
}