fluencelabs/fluence-js
1
0
Fork 0
mirror of https://github.com/fluencelabs/fluence-js.git synced 2025-06-14 16:41:21 +00:00
Code Issues Projects Releases Wiki Activity

fix: Increase number of inbound and outbound streams to 1024 (#280)

Browse Source
This commit is contained in:
Dima
2023-03-03 17:59:17 +07:00
committed by GitHub
parent 9ed1e2eafc
commit 1ccc483532
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/core/js-peer/src/connection/index.ts
View File

@ -135,6 +135,12 @@ export class RelayConnection extends FluenceConnection {
async connect(onIncomingParticle: ParticleHandler) { async connect(onIncomingParticle: ParticleHandler) {
await this._lib2p2Peer.start(); await this._lib2p2Peer.start();
// TODO: make it configurable
const handleOptions = {
maxInboundStreams: 1024,
maxOutboundStreams: 1024
}
this._lib2p2Peer.handle([PROTOCOL_NAME], async ({ connection, stream }) => { this._lib2p2Peer.handle([PROTOCOL_NAME], async ({ connection, stream }) => {
pipe( pipe(
stream.source, stream.source,
@ -156,7 +162,7 @@ export class RelayConnection extends FluenceConnection {
} }
}, },
); );
}); }, handleOptions);
log.debug(`dialing to the node with client's address: ` + this._lib2p2Peer.peerId.toString()); log.debug(`dialing to the node with client's address: ` + this._lib2p2Peer.peerId.toString());