Skip to content

Commit 6cb76f0

Browse files
committed
feat: add yamux stream muxer
1 parent 4d5f777 commit 6cb76f0

File tree

3 files changed

+16
-1
lines changed

3 files changed

+16
-1
lines changed

packages/beacon-node/package.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,7 @@
102102
"@chainsafe/discv5": "^5.0.0",
103103
"@chainsafe/libp2p-gossipsub": "^10.0.0",
104104
"@chainsafe/libp2p-noise": "^13.0.0",
105+
"@chainsafe/libp2p-yamux": "^5.0.0",
105106
"@chainsafe/persistent-merkle-tree": "^0.5.0",
106107
"@chainsafe/prometheus-gc-stats": "^1.0.0",
107108
"@chainsafe/ssz": "^0.10.2",

packages/beacon-node/src/network/libp2p/index.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ import {bootstrap} from "@libp2p/bootstrap";
77
import {mdns} from "@libp2p/mdns";
88
import {createLibp2p} from "libp2p";
99
import {mplex} from "@libp2p/mplex";
10+
import {yamux} from "@chainsafe/libp2p-yamux";
1011
import {prometheusMetrics} from "@libp2p/prometheus-metrics";
1112
import {tcp} from "@libp2p/tcp";
1213
import {defaultNetworkOptions, NetworkOptions} from "../options.js";
@@ -85,7 +86,7 @@ export async function createNodeJsLibp2p(
8586
},
8687
}),
8788
],
88-
streamMuxers: [mplex({maxInboundStreams: 256})],
89+
streamMuxers: [yamux({maxInboundStreams: 256}), mplex({maxInboundStreams: 256})],
8990
peerDiscovery,
9091
metrics: nodeJsLibp2pOpts.metrics
9192
? prometheusMetrics({

yarn.lock

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -606,6 +606,19 @@
606606
uint8arraylist "^2.4.3"
607607
uint8arrays "^4.0.4"
608608

609+
"@chainsafe/libp2p-yamux@^5.0.0":
610+
version "5.0.0"
611+
resolved "https://registry.yarnpkg.com/@chainsafe/libp2p-yamux/-/libp2p-yamux-5.0.0.tgz#c1016fc839870139b5c097daff9408b91c58f2a7"
612+
integrity sha512-aWTnBPR2hJt0A2y579sMtZVB6IqgSSHlZ6Eg+WDxNZQ0zcexafuruZQDj+z3FUTNPz+E8IeuyCi7tjI4IEehjw==
613+
dependencies:
614+
"@libp2p/interface" "^0.1.0"
615+
"@libp2p/logger" "^3.0.0"
616+
abortable-iterator "^5.0.1"
617+
it-foreach "^2.0.3"
618+
it-pipe "^3.0.1"
619+
it-pushable "^3.2.0"
620+
uint8arraylist "^2.4.3"
621+
609622
"@chainsafe/netmask@^2.0.0":
610623
version "2.0.0"
611624
resolved "https://registry.yarnpkg.com/@chainsafe/netmask/-/netmask-2.0.0.tgz#0d4a75f47919f65011da4327a3845c9661f1038a"

0 commit comments

Comments
 (0)