Почему take из RxJS пропускает все данные дальше без отсечения?

Question

[kodwi]

Из метода возвращаю цепочку, в конце которой .take(5).do(...). Но take не отрабатывает, не берет первые 5 элементов, а пропускает все, что ему пришло, дальше. Все подключено, ошибок / предупреждений в консоли нет вообще. В чем может быть проблема?

getGithubAccounts(firstName: string): Observable<GithubAccount[]> {
    return this.accountList ? Observable.of(this.accountList) :
      this.init
        .delay(this.delayTime)
        .switchMap(() => this._http.get(`${this.githubUrl}${firstName}`))
        .map(list => list.json().items)
        .take(5)
        .do(accountList => this.accountList = accountList);
  }

Comments

[frontender]

не припомню в js метода take

[kodwi]

frontender: забыл указать RxJS.

Answer 1

[_ _]

take отберет первые 5 событий из потока, в то время как у вас в потоке будет одно событие, содержащее список из пяти элементов. Чтобы в полученном списке оставить только первые пять элементов трансформируйте сам список

.map(list => list.json().items.slice(0, 5))