diff --git a/src/concurrent_stream/mod.rs b/src/concurrent_stream/mod.rs
index c599fac..ff79bc6 100644
--- a/src/concurrent_stream/mod.rs
+++ b/src/concurrent_stream/mod.rs
@@ -192,7 +192,7 @@ pub trait ConcurrentStream {
 /// The state of the consumer, used to communicate back to the source.
 #[derive(Debug)]
 pub enum ConsumerState {
-    /// The consumer is done making progress, and the `finish` method should be called.
+    /// The consumer is done making progress, and the `flush` method should be called.
     Break,
     /// The consumer is ready to keep making progress.
     Continue,