Skip to content

Commit 4abc07a

Browse files
committed
close super stream consumer
Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>
1 parent f1e6963 commit 4abc07a

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

examples/receive_super_stream.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
5656
}
5757
}
5858

59-
println!("Consumer stopped consuming.");
60-
// let _ = super_stream_consumer.close().await;
59+
println!("Stopping super stream consumer...");
60+
let _ = super_stream_consumer.handle().close().await;
61+
println!("Super stream consumer stopped");
6162
Ok(())
6263
}

0 commit comments

Comments
 (0)