Как сбросить RxJS, отличный от angular2 - PullRequest
Новая
       11

Как сбросить RxJS, отличный от angular2

1 голос
/ 23 марта 2019

Мне нужно реализовать бесконечную прокрутку, потому что мой внутренний ответ ограничен только для 100 элементов.Итак, при первой попытке страницы я получаю 100 предметов из бэкендаИ при каждой прокрутке до конца страницы мне нужна конечная точка вызова для еще 100 пунктов.

В моем дочернем компоненте (BpHistoryListInfiniteComponent) я установил атрибут data-load для отслеживания, когда появляется элемент 100.А затем с IntersectionObserver установите в Subject (pageByScroll$) значение атрибута загрузки данных.Мой pageByScroll$ должен начинаться с 0 (для первой попытки), и я использую distinct(), потому что мне нужно distinct уже загруженные элементы, а затем передать это значение моему родительскому компоненту.

Но после использованияодин из фильтров в родительском компоненте. Мне нужно сбросить значение index на 0, отправить его и отфильтровать значение в бэкэнд (и получить только 100 элементов), а затем, если пользователь прокручивает страницу вниз, мне нужно увеличить значение index с 0.еще раз, но distinct() не позволяет мне это.

Мне нужно как-то сбросить различные значения.

// html часть дочернего компонента 

<div #infiniteScrollMadness class="column">
  <div *ngFor="let item of history; let i = index" class="list" [attr.data-load]="(i + 1) % 100 == 0 ? (i + 1) : null">
    <span>{{ item.id }}</span>
    <span>{{ item.name }}</span>
  </div>
</div>

.ts часть childкомпонент 

export class BpHistoryListInfiniteComponent implements AfterViewInit {
    public pageByScroll$ = new Subject<number>();

    @ViewChild("infiniteScrollMadness")
    private scrollHost: ElementRef;

    @Input()
    history: HistoryModel;

    @Input()
    highlight: string;

    @Output()
    index = new EventEmitter<number>();

    ngAfterViewInit() {
        const intersectionObserver = new IntersectionObserver(
            entries => {
                entries
                    .filter(element => element.isIntersecting)
                    .forEach(element => {
                        this.pageByScroll$.next(
                            element.target.attributes["data-load"].value
                        );
                    });
            },
            {
                threshold: 0.1
            }
        );
        const mutationObserver = new MutationObserver(mutations => {
            mutations.forEach(mutation => {
                if (!mutation.addedNodes || mutation.type !== "childList") {
                    return;
                }
                const nodes = Array.prototype.slice.call(mutation.addedNodes, 0);

                nodes.filter(node => node.nodeType === Node.ELEMENT_NODE)
                    .forEach((element: Element) => {
                        if (element.attributes["data-load"]) {
                            this.zone.runOutsideAngular(() => {
                                intersectionObserver.observe(element);
                            });
                        }
                    });
            });
        });

        mutationObserver.observe(this.scrollHost.nativeElement, {
            childList: true
        });

        this.pageByScroll$.pipe(
            startWith(0),
            distinct()
        ).subscribe(index => this.index.emit(index));
    }

    constructor(private zone: NgZone) {}
}

pageByScroll$ поток:
- попытка первой страницы => значение: 0
- прокрутить вниз (+100) => значение: 100
- прокрутить вниз(+100) => значение: 200
- прокрутить вниз (+100) => значение: 300
- использовать один из фильтров => значение: 0
- прокрутить вниз (+100) => значение: 100
- прокрутить вниз (+100) => значение: 200

1 Ответ

2 голосов
/ 23 марта 2019

вы могли бы справиться с этим так 

this.resets$ = new Subject();
this.resets$.pipe(
  startWith(null),
  switchMap(() => this.pageByScroll$.pipe(
    startWith(0),
    distinct()
  ))
).subscribe(this.index);

это будет оператор "scope" distinct для switchMap, и вы можете вручную сбросить его с помощью this.resets$.next(null)

...