We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2879ce0 commit 404495cCopy full SHA for 404495c
tck/src/main/java/org/reactivestreams/tck/SubscriberBlackboxVerification.java
@@ -287,7 +287,16 @@ public void required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalW
287
public void run(BlackboxTestStage stage) throws Throwable {
288
final Publisher<T> pub = new Publisher<T>() {
289
@Override
290
- public void subscribe(Subscriber<? super T> s) {
+ public void subscribe(final Subscriber<? super T> s) {
291
+ s.onSubscribe(new Subscription() {
292
+ @Override public void request(long n) {
293
+ // do nothing...
294
+ }
295
+ @Override public void cancel() {
296
297
298
+ });
299
+ // immediately complete
300
s.onComplete();
301
}
302
};
0 commit comments