diff options
Diffstat (limited to 'node_modules/rxjs/src/internal/util/isReadableStreamLike.ts')
| -rw-r--r-- | node_modules/rxjs/src/internal/util/isReadableStreamLike.ts | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/node_modules/rxjs/src/internal/util/isReadableStreamLike.ts b/node_modules/rxjs/src/internal/util/isReadableStreamLike.ts deleted file mode 100644 index 87b9c15..0000000 --- a/node_modules/rxjs/src/internal/util/isReadableStreamLike.ts +++ /dev/null @@ -1,23 +0,0 @@ -import { ReadableStreamLike } from '../types'; -import { isFunction } from './isFunction'; - -export async function* readableStreamLikeToAsyncGenerator<T>(readableStream: ReadableStreamLike<T>): AsyncGenerator<T> { - const reader = readableStream.getReader(); - try { - while (true) { - const { value, done } = await reader.read(); - if (done) { - return; - } - yield value!; - } - } finally { - reader.releaseLock(); - } -} - -export function isReadableStreamLike<T>(obj: any): obj is ReadableStreamLike<T> { - // We don't want to use instanceof checks because they would return - // false for instances from another Realm, like an <iframe>. - return isFunction(obj?.getReader); -} |
