Skip to content

Commit 5ef3da1

Browse files
committed
update doc
1 parent c72b697 commit 5ef3da1

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

pubsub/README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -153,11 +153,11 @@ async fn run(config: ClientConfig) -> Result<(), Status> {
153153

154154
// Token for cancel.
155155
let cancel = CancellationToken::new();
156-
let cancel_fo_task = cancel.clone();
156+
let cancel_for_task = cancel.clone();
157157
tokio::spawn(async move {
158158
// Cancel after 10 seconds.
159159
tokio::time::sleep(Duration::from_secs(10)).await;
160-
cancel_fo_task.cancel();
160+
cancel_for_task.cancel();
161161
});
162162

163163
// Start receiving messages from the subscription.

pubsub/src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,11 +143,11 @@
143143
//!
144144
//! // Token for cancel.
145145
//! let cancel = CancellationToken::new();
146-
//! let cancel2 = cancel.clone();
146+
//! let cancel_for_task = cancel.clone();
147147
//! tokio::spawn(async move {
148148
//! // Cancel after 10 seconds.
149149
//! tokio::time::sleep(Duration::from_secs(10)).await;
150-
//! cancel2.cancel();
150+
//! cancel_for_task.cancel();
151151
//! });
152152
//!
153153
//! // Start receiving messages from the subscription.

0 commit comments

Comments
 (0)