File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change 11import { type ContentRouting , contentRouting } from '@libp2p/interface/content-routing'
22import { CodeError } from '@libp2p/interface/errors'
3+ import { setMaxListeners } from '@libp2p/interface/events'
34import { type PeerRouting , peerRouting } from '@libp2p/interface/peer-routing'
45import { logger } from '@libp2p/logger'
56import { peerIdFromString } from '@libp2p/peer-id'
@@ -39,6 +40,7 @@ export class DefaultDelegatedRoutingV1HttpApiClient implements DelegatedRoutingV
3940 constructor ( url : string | URL , init : DelegatedRoutingV1HttpApiClientInit = { } ) {
4041 this . started = false
4142 this . shutDownController = new AbortController ( )
43+ setMaxListeners ( Infinity , this . shutDownController . signal )
4244 this . httpQueue = new PQueue ( {
4345 concurrency : init . concurrentRequests ?? defaultValues . concurrentRequests
4446 } )
You can’t perform that action at this time.
0 commit comments