When the upstream is starting, the runtime is split in two instances: sink & stream, the former is started because gRPC implementation (bi streaming) is expecting to have some input before to send the connection, so the stream runtime is waiting before the first request. However there is a nit behind that, meanwhile the gRPC method + sink runtime are waiting, the upstream sink_rx+stream_rx have been sent to the runtime, the issue is about the stream_rx which might not be ready. For that we should handle in the runtime where an initial state the stream_rx is not ready yet, and will be confirmed by the Upstream stream runtime itself via channel, and once it's confirmed, it gonna be available.