takeWhile.js 582 B

1234567891011121314
  1. import { operate } from '../util/lift';
  2. import { createOperatorSubscriber } from './OperatorSubscriber';
  3. export function takeWhile(predicate, inclusive) {
  4. if (inclusive === void 0) { inclusive = false; }
  5. return operate(function (source, subscriber) {
  6. var index = 0;
  7. source.subscribe(createOperatorSubscriber(subscriber, function (value) {
  8. var result = predicate(value, index++);
  9. (result || inclusive) && subscriber.next(value);
  10. !result && subscriber.complete();
  11. }));
  12. });
  13. }
  14. //# sourceMappingURL=takeWhile.js.map