Skip to content

Commit

Permalink
examples: fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
mwtian committed Apr 26, 2024
1 parent 068421a commit 55993ca
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion examples/src/streaming/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ async fn streaming_echo(client: &mut EchoClient<Channel>, 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<Channel>, num: usize) {
Expand Down
2 changes: 1 addition & 1 deletion examples/src/streaming/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 55993ca

Please sign in to comment.