From 55993ca518f7d75842420bbc7a73abd59355c7e8 Mon Sep 17 00:00:00 2001 From: Mingwei Tian Date: Thu, 21 Mar 2024 22:07:41 -0700 Subject: [PATCH] examples: fix typo --- examples/src/streaming/client.rs | 2 +- examples/src/streaming/server.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/src/streaming/client.rs b/examples/src/streaming/client.rs index 0f8e28aaf..546f244ff 100644 --- a/examples/src/streaming/client.rs +++ b/examples/src/streaming/client.rs @@ -28,7 +28,7 @@ async fn streaming_echo(client: &mut EchoClient, num: usize) { while let Some(item) = stream.next().await { println!("\treceived: {}", item.unwrap().message); } - // stream is droped here and the disconnect info is send to server + // stream is dropped here and the disconnect info is sent to server } async fn bidirectional_streaming_echo(client: &mut EchoClient, num: usize) { diff --git a/examples/src/streaming/server.rs b/examples/src/streaming/server.rs index 34d03fa0c..1fbb91e0b 100644 --- a/examples/src/streaming/server.rs +++ b/examples/src/streaming/server.rs @@ -103,7 +103,7 @@ impl pb::echo_server::Echo for EchoServer { // this spawn here is required if you want to handle connection error. // If we just map `in_stream` and write it back as `out_stream` the `out_stream` - // will be drooped when connection error occurs and error will never be propagated + // will be dropped when connection error occurs and error will never be propagated // to mapped version of `in_stream`. tokio::spawn(async move { while let Some(result) = in_stream.next().await {