problem: WS proxy uses binary frames (#182)
fix: #180
(cherry picked from commit 2dcb56e8c4467cfdc549fe918427fce593703ca3)
(cherry picked from commit 5df10706dd)
This commit is contained in:
@@ -27,7 +27,6 @@ import io.emeraldpay.dshackle.rpc.NativeSubscribe
|
||||
import io.emeraldpay.etherjar.rpc.json.RequestJson
|
||||
import io.emeraldpay.etherjar.rpc.json.ResponseJson
|
||||
import io.netty.buffer.ByteBufInputStream
|
||||
import io.netty.buffer.Unpooled
|
||||
import org.reactivestreams.Publisher
|
||||
import org.slf4j.LoggerFactory
|
||||
import reactor.core.publisher.Flux
|
||||
@@ -74,9 +73,8 @@ class WebsocketHandler(
|
||||
val eventHandler = accessHandler.start(req, routeConfig.blockchain)
|
||||
|
||||
val responses = respond(routeConfig.blockchain, control, requests, eventHandler)
|
||||
.map { Unpooled.wrappedBuffer(it.toByteArray()) }
|
||||
|
||||
resp.send(responses)
|
||||
resp.sendString(responses, Charsets.UTF_8)
|
||||
.then()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user