aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/esm/internal/util/isReadableStreamLike.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/util/isReadableStreamLike.js')
-rw-r--r--node_modules/rxjs/dist/esm/internal/util/isReadableStreamLike.js23
1 files changed, 23 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/util/isReadableStreamLike.js b/node_modules/rxjs/dist/esm/internal/util/isReadableStreamLike.js
new file mode 100644
index 0000000..bc75c6d
--- /dev/null
+++ b/node_modules/rxjs/dist/esm/internal/util/isReadableStreamLike.js
@@ -0,0 +1,23 @@
+import { __asyncGenerator, __await } from "tslib";
+import { isFunction } from './isFunction';
+export function readableStreamLikeToAsyncGenerator(readableStream) {
+ return __asyncGenerator(this, arguments, function* readableStreamLikeToAsyncGenerator_1() {
+ const reader = readableStream.getReader();
+ try {
+ while (true) {
+ const { value, done } = yield __await(reader.read());
+ if (done) {
+ return yield __await(void 0);
+ }
+ yield yield __await(value);
+ }
+ }
+ finally {
+ reader.releaseLock();
+ }
+ });
+}
+export function isReadableStreamLike(obj) {
+ return isFunction(obj === null || obj === void 0 ? void 0 : obj.getReader);
+}
+//# sourceMappingURL=isReadableStreamLike.js.map \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage