We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2879ce0 commit ae56360Copy full SHA for ae56360
tck/src/main/java/org/reactivestreams/tck/IdentityProcessorVerification.java
@@ -649,13 +649,13 @@ public TestSetup apply(Long subscribers) throws Throwable {
649
expectNextElement(sub1, x);
650
651
if (totalRequests == 1) {
652
- totalRequests += expectRequest();
+ totalRequests= expectRequest();
653
}
654
final T y = sendNextTFromUpstream();
655
expectNextElement(sub1, y);
656
657
if (totalRequests == 2) {
658
659
660
661
final ManualSubscriber<T> sub2 = newSubscriber();
0 commit comments