i have a rust client done in Tonic, my proto is a single method with stream request and stream response(bidirectional stream)
let req = Request::new(tokio_stream::iter(vec![data]));
match self.client.put_data(req).await {
Ok(res) => {
if let Ok(Some(msg)) = res.into_inner().message().await {
self.stat = msg.data
}
}
Err(err) => {
return Err(Box::new(err))
},
}
pretty default, but after first successfull message sent im always receiving
status: Unavailable, message: "tcp connect error: Connection refused (os error 111)", details: , metadata: MetadataMap { headers: {} }
message, connection is established successfully on start of the application, first message is always successful, every other message is tcp connect error, seems like connection is closing after each message???? or what do i do wrong, any ideas?
servers is working fine, same client on same protobuf in Java works fine, so keepalive is not an issue