use text format in ws communication

2024-02-13 22:39:42 +03:00
parent db94d36097
commit aa4f569ce2
1 changed files with 3 additions and 3 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnectionImpl.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnectionImpl.kt
@@ -286,13 +286,13 @@ open class WsConnectionImpl(
        val calls = rpcSend
            .asFlux()
            .map {
-                Unpooled.wrappedBuffer(it.toJson())
+                it.toString()
            }
-        return outbound.send(
+        return outbound.sendString(
            Flux.merge(
                calls.subscribeOn(scheduler),
-                consumer.then(Mono.empty<ByteBuf>()).subscribeOn(scheduler),
+                consumer.then(Mono.empty<String>()).subscribeOn(scheduler),
            ),
        )
    }