From afb7d2d5c6ca09d2c678781ae4dd3f527604c1b4 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Thu, 14 Oct 2021 11:50:22 +0200 Subject: Remove protractor workaround We don't use it anymore --- client/src/app/helpers/rxjs.ts | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) (limited to 'client/src/app/helpers/rxjs.ts') diff --git a/client/src/app/helpers/rxjs.ts b/client/src/app/helpers/rxjs.ts index eb051f868..625bca0f7 100644 --- a/client/src/app/helpers/rxjs.ts +++ b/client/src/app/helpers/rxjs.ts @@ -1,24 +1,19 @@ import { uniq } from 'lodash-es' -import { asyncScheduler, Observable } from 'rxjs' -import { bufferTime, distinctUntilChanged, filter, map, observeOn, share, switchMap } from 'rxjs/operators' -import { NgZone } from '@angular/core' -import { enterZone, leaveZone } from './zone' +import { Observable } from 'rxjs' +import { bufferTime, distinctUntilChanged, filter, map, share, switchMap } from 'rxjs/operators' function buildBulkObservable (options: { - ngZone: NgZone notifierObservable: Observable time: number bulkGet: (params: T[]) => Observable }) { - const { ngZone, notifierObservable, time, bulkGet } = options + const { notifierObservable, time, bulkGet } = options return notifierObservable.pipe( distinctUntilChanged(), - // We leave Angular zone so Protractor does not get stuck - bufferTime(time, leaveZone(ngZone, asyncScheduler)), + bufferTime(time), filter(params => params.length !== 0), map(params => uniq(params)), - observeOn(enterZone(ngZone, asyncScheduler)), switchMap(params => bulkGet(params)), share() ) -- cgit v1.2.3