Function makeWork

operators/src/queueOnlyLatest.ts:46–48

(trigger: T)

      };

      function makeWork(trigger: T) {
        return from(workCreator(trigger)).pipe(withLatestFrom(of(trigger)));
      }

      return source.subscribe({
        next(trigger) {