fixed FAIL_NON_SERIALIZED error

This commit is contained in:
Maxksim Fomenkov
2022-09-08 03:51:06 +03:00
parent 4e0a7de1bf
commit 0a9f27c009

View File

@@ -388,10 +388,7 @@ open class WsConnection(
fun sendRpc(request: JsonRpcRequest) {
// submit to upstream in a separate thread, to free current thread (needs for subscription, etc)
sendExecutor.execute {
val result = rpcSend.tryEmitNext(request)
if (result.isFailure) {
log.warn("Failed to send RPC request: $result")
}
rpcSend.emitNext(request) { _, res -> res == Sinks.EmitResult.FAIL_NON_SERIALIZED }
}
}