PATH:
usr
/
local
/
lib
/
node_modules
/
ghost-cli
/
node_modules
/
rxjs
/
src
/
internal
/
util
import { Subscriber } from '../Subscriber'; import { iterator as Symbol_iterator } from '../symbol/iterator'; export const subscribeToIterable = <T>(iterable: Iterable<T>) => (subscriber: Subscriber<T>) => { const iterator = iterable[Symbol_iterator](); do { const item = iterator.next(); if (item.done) { subscriber.complete(); break; } subscriber.next(item.value); if (subscriber.closed) { break; } } while (true); // Finalize the iterator if it happens to be a Generator if (typeof iterator.return === 'function') { subscriber.add(() => { if (iterator.return) { iterator.return(); } }); } return subscriber; };
[-] subscribeToResult.ts
[edit]
[-] isInteropObservable.ts
[edit]
[-] isArrayLike.ts
[edit]
[-] EmptyError.ts
[edit]
[-] subscribeToPromise.ts
[edit]
[-] isScheduler.ts
[edit]
[-] root.ts
[edit]
[+]
..
[-] applyMixins.ts
[edit]
[-] isObservable.ts
[edit]
[-] tryCatch.ts
[edit]
[-] subscribeToIterable.ts
[edit]
[-] subscribeToArray.ts
[edit]
[-] isPromise.ts
[edit]
[-] pipe.ts
[edit]
[-] identity.ts
[edit]
[-] ArgumentOutOfRangeError.ts
[edit]
[-] ObjectUnsubscribedError.ts
[edit]
[-] isIterable.ts
[edit]
[-] UnsubscriptionError.ts
[edit]
[-] not.ts
[edit]
[-] isArray.ts
[edit]
[-] isObject.ts
[edit]
[-] isNumeric.ts
[edit]
[-] isFunction.ts
[edit]
[-] noop.ts
[edit]
[-] canReportError.ts
[edit]
[-] errorObject.ts
[edit]
[-] TimeoutError.ts
[edit]
[-] isDate.ts
[edit]
[-] subscribeToObservable.ts
[edit]
[-] subscribeTo.ts
[edit]
[-] hostReportError.ts
[edit]
[-] toSubscriber.ts
[edit]
[-] Immediate.ts
[edit]