Function nextViaMapper

operators/src/queueOnlyLatest.ts:31–34

([result, trigger]: [R, T])

      // each new concurrent request overwrites this
      let nextWork: Observable<R> | null;
      const nextViaMapper = ([result, trigger]: [R, T]) => {
        const _result = (mapper ? mapper(trigger, result) : result) as S;
        notify.next(_result);
      };

      let workObserver: PartialObserver<[R, T]> = {
        complete() {