mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-02-23 22:56:52 +01:00
Code Issues Projects Releases Packages Wiki Activity

increase buffer size of dataMessageStream to 10000 (#4646)

Browse source
This commit is contained in:
Shreyansh 2022-08-23 19:29:16 +05:30 • committed by GitHub
parent e5545cb3b9
commit 068187c93d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
node/src/main/scala/org/bitcoins/node/PeerManager.scala
View file

@ -376,7 +376,7 @@ case class PeerManager(
}
private val dataMessageStreamSource = Source
.queue[StreamDataMessageWrapper](1000,
.queue[StreamDataMessageWrapper](10000,
overflowStrategy = OverflowStrategy.fail)
.mapAsync(1) {
case msg @ DataMessageWrapper(payload, peerMsgSender, peer) =>