fix: window is not defined in worker contexts

package.json

@@ -148,7 +148,7 @@
     "lint": "aegir lint",
     "dep-check": "aegir dep-check",
     "build": "aegir build",
-    "test": "aegir test -t browser",
+    "test": "aegir test -t browser -t webworker",
     "test:chrome": "aegir test -t browser --cov",
     "test:chrome-webworker": "aegir test -t webworker",
     "release": "aegir release",
@@ -168,7 +168,6 @@
     "uint8arraylist": "^2.3.3"
   },
   "devDependencies": {
-    "@fails-components/webtransport": "^0.1.5",
     "aegir": "^38.1.7",
     "libp2p": "^0.43.2"
   },

src/index.ts

@@ -11,6 +11,10 @@ import type { Duplex, Source } from 'it-stream-types'
 import type { StreamMuxerFactory, StreamMuxerInit, StreamMuxer } from '@libp2p/interface-stream-muxer'
 import { Uint8ArrayList } from 'uint8arraylist'
 
+declare global {
+  var WebTransport: any
+}
+
 const log = logger('libp2p:webtransport')
 
 // @ts-expect-error - Not easy to combine these types.
@@ -359,7 +363,7 @@ class WebTransportTransport implements Transport {
             yield val.value
           }
 
-          if (val.done) {
+          if (val.done === true) {
             break
           }
         }
@@ -413,9 +417,11 @@ class WebTransportTransport implements Transport {
           const reader = wt.incomingBidirectionalStreams.getReader()
           while (true) {
             const { done, value: wtStream } = await reader.read()
-            if (done) {
+
+            if (done === true) {
               break
             }
+
             if (activeStreams.length >= config.maxInboundStreams) {
               // We've reached our limit, close this stream.
               wtStream.writable.close().catch((err: Error) => {