Merge pull request #400 from syphar/fix-docs-subscribe

fix documentation where `tokio::select!` was used with `.await`

Author: yoshidan

pubsub/README.md

@@ -167,16 +167,16 @@ async fn run(config: ClientConfig) -> Result<(), Status> {
     while let Some(message) = tokio::select!{
         v = iter.next() => v,
         _ = ctx.cancelled() => None,
-    }.await {
+    } {
         let _ = message.ack().await;
     }
     // Wait for all the unprocessed messages to be Nack.
     // If you don't call dispose, the unprocessed messages will be Nack when the iterator is dropped.
-    iter.dispose().await;    
-        
+    iter.dispose().await;
+
     // Delete subscription if needed.
     subscription.delete(None).await?;
 
     Ok(())
 }
-```
+```

pubsub/src/lib.rs

@@ -157,7 +157,7 @@
 //!     while let Some(message) = tokio::select!{
 //!         v = iter.next() => v,
 //!         _ = cancel.cancelled() => None,
-//!     }.await {
+//!     } {
 //!         let _ = message.ack().await;
 //!     }
 //!     // Wait for all the unprocessed messages to be Nack.

pubsub/src/subscription.rs

@@ -449,7 +449,7 @@ impl Subscription {
     ///     while let Some(message) = tokio::select!{
     ///         v = iter.next() => v,
     ///         _ = ctx.cancelled() => None,
-    ///     }.await {
+    ///     } {
     ///         let _ = message.ack().await;
     ///     }
     ///     // Wait for all the unprocessed messages to be Nack.