Revert "problem: timeout on unit tests"

src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt

@@ -405,8 +405,7 @@ open class WsConnection(
         )
 
         val response = Flux.from(rpcReceive.asFlux())
-            // send the request _after_ WS subscribes to the responses, otherwise the response may come before the actual subscription and be lost
-            .doOnRequest { sendRpc(request) }
+            .doOnSubscribe { sendRpc(request) }
             .filter { resp -> resp.id.asNumber() == expectedId }
             .take(Defaults.timeout)
             .take(1)