3b41af77516f2b1136d511a68f507fde1e8f100a40032fa35e1e656cc200df50a4936823d37e11464b69ae6aa856e1a271fac534aef1ed4592af8c8b366e6b 521 B

1234567891011
  1. import { operate } from '../util/lift';
  2. import { createOperatorSubscriber } from './OperatorSubscriber';
  3. import { innerFrom } from '../observable/innerFrom';
  4. import { noop } from '../util/noop';
  5. export function takeUntil(notifier) {
  6. return operate(function (source, subscriber) {
  7. innerFrom(notifier).subscribe(createOperatorSubscriber(subscriber, function () { return subscriber.complete(); }, noop));
  8. !subscriber.closed && source.subscribe(subscriber);
  9. });
  10. }
  11. //# sourceMappingURL=takeUntil.js.map