From aa4f569ce2a02a8ae3ba26d28c8abcb533dfa743 Mon Sep 17 00:00:00 2001
From: a10zn8 <a1.cyb3r@gmail.com>
Date: Tue, 13 Feb 2024 22:39:42 +0300
Subject: [PATCH] use text format in ws communication

---
 .../dshackle/upstream/ethereum/WsConnectionImpl.kt          | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnectionImpl.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnectionImpl.kt
index d18129de..28922052 100644
--- 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),
             ),
         )
     }