We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3481ed1 commit 5278124Copy full SHA for 5278124
src/main/java/io/reactivex/internal/operators/parallel/ParallelJoin.java
@@ -110,15 +110,13 @@ public void cancel() {
110
}
111
112
void cancelAll() {
113
- for (int i = 0; i < subscribers.length; i++) {
114
- JoinInnerSubscriber<T> s = subscribers[i];
+ for (JoinInnerSubscriber<T> s : subscribers) {
115
s.cancel();
116
117
118
119
void cleanup() {
120
121
122
s.queue = null;
123
124
0 commit comments