refactor: remove use of timeout-abort-controller (#148)

libp2p · May 3, 2023 · 0a72552 · 0a72552
1 parent 68b446d
commit 0a72552
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/package.json b/package.json
@@ -161,7 +161,6 @@
     "multihashes": "^4.0.3",
     "p-defer": "^4.0.0",
     "protons-runtime": "^5.0.0",
-    "timeout-abort-controller": "^3.0.0",
     "uint8arraylist": "^2.3.3",
     "uint8arrays": "^4.0.2",
     "detect-browser": "^5.3.0"

diff --git a/src/peer_transport/handler.ts b/src/peer_transport/handler.ts
@@ -1,7 +1,6 @@
 import type { IncomingStreamData } from '@libp2p/interface-registrar'
 import { pbStream } from 'it-pb-stream'
 import pDefer, { type DeferredPromise } from 'p-defer'
-import { TimeoutController } from 'timeout-abort-controller'
 import { readCandidatesUntilConnected, resolveOnConnected } from './util.js'
 import * as pb from './pb/index.js'
 import { abortableDuplex } from 'abortable-iterator'
@@ -17,9 +16,8 @@ const log = logger('libp2p:webrtc:peer')
 export type IncomingStreamOpts = { rtcConfiguration?: RTCConfiguration } & IncomingStreamData
 
 export async function handleIncomingStream ({ rtcConfiguration, stream: rawStream }: IncomingStreamOpts): Promise<[RTCPeerConnection, StreamMuxerFactory]> {
-  const timeoutController = new TimeoutController(DEFAULT_TIMEOUT)
-  const signal = timeoutController.signal
-  const stream = pbStream(abortableDuplex(rawStream, timeoutController.signal)).pb(pb.Message)
+  const signal = AbortSignal.timeout(DEFAULT_TIMEOUT)
+  const stream = pbStream(abortableDuplex(rawStream, signal)).pb(pb.Message)
   const pc = new RTCPeerConnection(rtcConfiguration)
   const muxerFactory = new DataChannelMuxerFactory(pc)