Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

8232367: Update Reactive Streams to 1.0.3 -- tests only #2921

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

8232367: Update Reactive Streams to 1.0.3 -- tests only #2921

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 9 additions & 2 deletions ...ttpclient/reactivestreams-tck/org/reactivestreams/tck/SubscriberWhiteboxVerification.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -278,8 +278,9 @@ public void required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCall
@Override
public void run(WhiteboxTestStage stage) throws InterruptedException {
stage.puppet().triggerRequest(1);
stage.puppet().signalCancel();
stage.expectRequest();
stage.puppet().signalCancel();
stage.expectCancelling();
stage.signalNext();

stage.puppet().triggerRequest(1);
Expand Down Expand Up @@ -824,11 +825,17 @@ public interface SubscriberPuppet {
* Before sending any element to the subscriber, the TCK must wait for the subscriber to request that element, and
* must be prepared for the subscriber to only request one element at a time, it is not enough for the TCK to
* simply invoke this method before sending elements.
* <p>
* An invocation of {@link #signalCancel()} may be coalesced into any elements that have not yet been requested,
* such that only a cancel signal is emitted.
*/
void triggerRequest(long elements);

/**
* Trigger {@code cancel()} on your {@link Subscriber}
* Trigger {@code cancel()} on your {@link Subscriber}.
* <p>
* An invocation of this method may be coalesced into any outstanding requests, as requested by
*{@link #triggerRequest(long)}, such that only a cancel signal is emitted.
*/
void signalCancel();
}
Expand Down