Use isStreamx()

holepunchto · Dec 12, 2024 · 89422df · 89422df
1 parent 93b9b57
commit 89422df
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/web.js b/web.js
@@ -1,4 +1,4 @@
-const { Readable, getStreamError, isStream, isDisturbed } = require('streamx')
+const { Readable, getStreamError, isStreamx, isDisturbed } = require('streamx')
 
 // https://streams.spec.whatwg.org/#readablestreamdefaultreader
 exports.ReadableStreamDefaultReader = class ReadableStreamDefaultReader {
@@ -98,7 +98,7 @@ exports.ReadableStreamDefaultController = class ReadableStreamDefaultController
 // https://streams.spec.whatwg.org/#readablestream
 exports.ReadableStream = class ReadableStream {
   constructor(underlyingSource = {}, queuingStrategy) {
-    if (isStream(underlyingSource)) {
+    if (isStreamx(underlyingSource)) {
       this._stream = underlyingSource
     } else {
       if (queuingStrategy === undefined) {