Current implementation opens an RPC stream to a fresh peer on libp2p level. When response for a query is used, first outgoing stream is used to send it, and it is always incorrect, as for query also outgoing stream is used, but from the other side, so it should be incoming for the responder.