Rxjs, проблема при объединении данных - PullRequest
0 голосов
/ 04 декабря 2018

У меня есть тема поведения в моей заявке.и я подписался на эту тему поведения, как показано ниже.

 tableData: BehaviorSubject<any> = new BehaviorSubject([]);

Я использую метод next () для установки данных из какой-либо другой функции, как показано ниже

for (let item of data) {
    let objArr = [];
    // some code here like for loop (i am processing 100k records)

    objArr.push(object);
    if (objArr.length == 20) {
        this.tableData.next(objArr);
        objArr = [];
    } 
}

Я подписался на этот BehaviourSubject, как показано ниже.но я не могу показать все записи из БД.

this.data = [];
this.utilServ.tableData.subscribe((data) => {
    if (data.length !== 0) {
        for (let item of data) {
            this.data.push(item);
        }
    }
});
this.utilServ.tableData.next([]);

Показываются только последние записи.

Как объединить / объединить / объединить данные из Поведения субъекта?

1 Ответ

0 голосов
/ 04 декабря 2018

Когда вы используете next из behaviorSubject, вы можете использовать next для накопленного массива.

Один из способов написать так

const newValue = this.tableData.value.concat(objArr);
this.tableData.next(newValue);
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...