Skip to content

Commit ba38f73

Browse files
committed
Change subscription remove logic.
1 parent c28d4c7 commit ba38f73

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

tck/src/test/java/org/reactivestreams/tck/PublisherVerificationTest.java

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -787,13 +787,7 @@ public void request(long n) {
787787
public void cancel() {
788788
canceled.set(true);
789789
subscriber = null;
790-
// COR list, so its ok to remove demand that way
791-
for (CancelableSubscription subscription : subscriptions) {
792-
// reference equality. It's ok
793-
if (subscription == this) {
794-
subscriptions.remove(subscription);
795-
}
796-
}
790+
subscriptions.remove(this);
797791
}
798792
}
799793

0 commit comments

Comments
 (0)