File tree 1 file changed +9
-2
lines changed
tck/src/main/java/org/reactivestreams/tck
1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -266,8 +266,9 @@ public void required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCall
266
266
@ Override
267
267
public void run (WhiteboxTestStage stage ) throws InterruptedException {
268
268
stage .puppet ().triggerRequest (1 );
269
- stage .puppet ().signalCancel ();
270
269
stage .expectRequest ();
270
+ stage .puppet ().signalCancel ();
271
+ stage .expectCancelling ();
271
272
stage .signalNext ();
272
273
273
274
stage .puppet ().triggerRequest (1 );
@@ -812,11 +813,17 @@ public interface SubscriberPuppet {
812
813
* Before sending any element to the subscriber, the TCK must wait for the subscriber to request that element, and
813
814
* must be prepared for the subscriber to only request one element at a time, it is not enough for the TCK to
814
815
* simply invoke this method before sending elements.
816
+ * <p>
817
+ * An invocation of {@link #signalCancel()} may be coalesced into any elements that have not yet been requested,
818
+ * such that only a cancel signal is emitted.
815
819
*/
816
820
void triggerRequest (long elements );
817
821
818
822
/**
819
- * Trigger {@code cancel()} on your {@link Subscriber}
823
+ * Trigger {@code cancel()} on your {@link Subscriber}.
824
+ * <p/>
825
+ * An invocation of this method may be coalesced into any outstanding requests, as requested by
826
+ * {@link #triggerRequest(long)}, such that only a cancel signal is emitted.
820
827
*/
821
828
void signalCancel ();
822
829
}
You can’t perform that action at this time.
0 commit comments