diff --git a/tck/src/main/java/org/reactivestreams/tck/PublisherVerification.java b/tck/src/main/java/org/reactivestreams/tck/PublisherVerification.java index c2f46576..12d1b682 100644 --- a/tck/src/main/java/org/reactivestreams/tck/PublisherVerification.java +++ b/tck/src/main/java/org/reactivestreams/tck/PublisherVerification.java @@ -361,6 +361,10 @@ public void run(final Publisher pub) throws InterruptedException { public void onSubscribe(Subscription subs) { onSubscribeLatch.assertOpen("Only one onSubscribe call expected"); onSubscribeLatch.close(); + + // If the publisher requires a request to publish the error, that follows the spec + // If it does not, this should be a no-op + subs.request(1); } @Override public void onError(Throwable cause) { @@ -527,6 +531,10 @@ public void onError(Throwable cause) { public void onSubscribe(Subscription subs) { onSubscribeLatch.assertOpen("Only one onSubscribe call expected"); onSubscribeLatch.close(); + + // If the publisher requires a request to publish the error, that follows the spec + // If it does not, this should be a no-op + subs.request(1); } }; pub.subscribe(sub);