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