fix formatting
This commit is contained in:
@@ -165,7 +165,8 @@ open class WsConnection(
|
|||||||
reconnecting.set(false)
|
reconnecting.set(false)
|
||||||
connectInternal()
|
connectInternal()
|
||||||
},
|
},
|
||||||
retryInterval, TimeUnit.MILLISECONDS
|
retryInterval,
|
||||||
|
TimeUnit.MILLISECONDS
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -298,7 +299,10 @@ open class WsConnection(
|
|||||||
fun onRpc(msg: ResponseWSParser.WsResponse): Mono<Void> {
|
fun onRpc(msg: ResponseWSParser.WsResponse): Mono<Void> {
|
||||||
return if (msg.id.isNumber()) {
|
return if (msg.id.isNumber()) {
|
||||||
val resp = JsonRpcResponse(
|
val resp = JsonRpcResponse(
|
||||||
msg.value, msg.error, msg.id, null
|
msg.value,
|
||||||
|
msg.error,
|
||||||
|
msg.id,
|
||||||
|
null
|
||||||
)
|
)
|
||||||
Mono.fromCallable {
|
Mono.fromCallable {
|
||||||
val status = rpcReceive.tryEmitNext(resp)
|
val status = rpcReceive.tryEmitNext(resp)
|
||||||
|
|||||||
Reference in New Issue
Block a user