StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix proxy newHeads sub (#446)

Browse Source
This commit is contained in:
KirillPamPam
2024-03-29 19:25:43 +04:00
committed by GitHub
parent 7e9709bb6f
commit 2bedcad9dc
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/kotlin/io/emeraldpay/dshackle/proxy/WebsocketHandler.kt
View File

@@ -139,7 +139,12 @@ class WebsocketHandler(
val responses = nativeSubscribe val responses = nativeSubscribe
.subscribe(blockchain, methodParams.first, methodParams.second, io.emeraldpay.dshackle.upstream.Selector.empty) .subscribe(blockchain, methodParams.first, methodParams.second, io.emeraldpay.dshackle.upstream.Selector.empty)
.map { event -> .map { event ->
WsSubscriptionResponse(params = WsSubscriptionData(event, subscriptionId)) val data = if (event is ByteArray) {
Global.objectMapper.readTree(event)
} else {
event
}
WsSubscriptionResponse(params = WsSubscriptionData(data, subscriptionId))
} }
.takeUntilOther(currentControl.asMono()) .takeUntilOther(currentControl.asMono())
Flux.concat(Mono.just(start), responses) Flux.concat(Mono.just(start), responses)