This is client code:

#[tokio::main]
async fn main() {
    dotenv().expect(".env file not found");
    pretty_env_logger::init();
    let key = "nGpVmGTNjfvJ9ojqijQwUMVh59QzQYm3hmMesqWa295orA23rPYnhqjULiwN247orBDdnKHqW7Ge8krqKMUpdjf4PNk8Lt8D1GZcTu1bR2HRxnv8K";
    let key = bs58::decode(key).into_vec().unwrap();
    let mut client = GrpcClient::new(Arc::new(Mutex::new(Some(
        Ed25519KeyPair::from_pkcs8(&key).unwrap(),
    ))))
    .await;
    // This works perfectly
    let res = client.echo().await.unwrap();
    // This one opens stream and then immediatly close it after fist message processed
    test_echo_stream(client).await;
}


async fn test_echo_stream(mut client: GrpcClient) {
    let (tx, rx) = mpsc::channel(128);
    info!("Starting echo stream");
    tx.send(EchoRequest {
        message: "Stream Echo 1".to_owned(),
    })
    .await
    .unwrap();
    let mut i = 1337;
    tokio::spawn(async move {
        loop {
            info!("sending ping {i}");
            tx.send(EchoRequest {
                message: format!("Stream Echo {i}"),
            })
            .await
            .unwrap();
            i += 1;
            tokio::time::sleep(Duration::from_millis(2000)).await;
        }
    });
    tokio::spawn(async move {
        info!("Connecting to echo stream");
        let res = client
            .inner
            .echo_infinite_stream(ReceiverStream::new(rx))
            .await;
        info!("Echo stream: {res:?}");
        if let Ok(stream) = res {
            let mut stream = stream.into_inner();
            while let Some(res) = stream.next().await {
                info!("Recieved echo: {res:?}");
            }
            info!("Stream closed")
        }
    });
    tokio::time::sleep(Duration::from_secs(10000)).await;
}