parent
7b222af1dd
commit
9b52376e7a
@ -67,13 +67,16 @@ impl GrpcClient {
|
||||
namespace: namespace.into(),
|
||||
id: id.map(|i| i.into()),
|
||||
})
|
||||
.await?;
|
||||
.await
|
||||
.inspect_err(|e| tracing::warn!("failed to establish a connection: {}", e))?;
|
||||
|
||||
tracing::debug!("setup stream: {}", namespace);
|
||||
let mut inner = resp.into_inner();
|
||||
while let Ok(Some(message)) = inner.message().await {
|
||||
tracing::debug!("received message: {}", namespace);
|
||||
exec.execute(message).await?;
|
||||
exec.execute(message)
|
||||
.await
|
||||
.inspect_err(|e| tracing::warn!("failed to handle message: {}", e))?;
|
||||
}
|
||||
|
||||
Ok(())
|
||||
|
Loading…
x
Reference in New Issue
Block a user