Skip to content

Commit 8648248

Browse files
committed
add comment
1 parent d9fef5d commit 8648248

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/github/davidmoten/rx2/internal/flowable/FlowableCollectWhile.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ private static final class CollectWhileSubscriber<T, R> extends AtomicInteger
5858
private Subscription parent;
5959
private volatile R collection;
6060
private volatile boolean done;
61-
private Throwable error;
61+
private Throwable error; // does not need to be volatile because is set before `done` and read after `done`
6262

6363
private volatile boolean cancelled;
6464

0 commit comments

Comments
 (0)