diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToIterable.ts')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToIterable.ts | 28 |
1 files changed, 0 insertions, 28 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToIterable.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToIterable.ts deleted file mode 100644 index 6d20f689ff..0000000000 --- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToIterable.ts +++ /dev/null @@ -1,28 +0,0 @@ -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; -}; |