mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2024-11-19 18:02:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

change stream to use backpressure (#4654)

Browse Source
This commit is contained in:
Shreyansh 2022-08-24 02:24:15 +05:30 committed by GitHub
parent 288918d705
commit 4e4e4aa9ed
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
node/src/main/scala/org/bitcoins/node/PeerManager.scala
View File

@ -376,8 +376,9 @@ case class PeerManager(
}
private val dataMessageStreamSource = Source
.queue[StreamDataMessageWrapper](10000,
overflowStrategy = OverflowStrategy.fail)
.queue[StreamDataMessageWrapper](1500,
overflowStrategy =
OverflowStrategy.backpressure)
.mapAsync(1) {
case msg @ DataMessageWrapper(payload, peerMsgSender, peer) =>
logger.debug(s"Got ${payload.commandName} from ${peer} in stream")