diff --git a/src/main/java/io/reactivex/rxjava3/core/Flowable.java b/src/main/java/io/reactivex/rxjava3/core/Flowable.java index dab6c437d7..73ea226256 100644 --- a/src/main/java/io/reactivex/rxjava3/core/Flowable.java +++ b/src/main/java/io/reactivex/rxjava3/core/Flowable.java @@ -114,7 +114,7 @@ * Thread.sleep(1000); * * // the consumer might have cancelled the flow - * if (emitter.isCancelled() { + * if (emitter.isCancelled()) { * return; * } *