Enable error state Reactive-Streams TCK verifications for BufferingPu…

…blisher (ratpack#436)
burkad01 · Sep 4, 2014 · b56be91 · b56be91
1 parent e4160e9
commit b56be91
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/ratpack-core/src/test/groovy/ratpack/stream/tck/BufferingPublisherVerification.groovy b/ratpack-core/src/test/groovy/ratpack/stream/tck/BufferingPublisherVerification.groovy
@@ -17,6 +17,7 @@
 package ratpack.stream.tck
 
 import org.reactivestreams.Publisher
+import org.reactivestreams.Subscriber
 import org.reactivestreams.tck.PublisherVerification
 import org.reactivestreams.tck.TestEnvironment
 
@@ -42,7 +43,11 @@ class BufferingPublisherVerification extends PublisherVerification<Integer> {
 
   @Override
   Publisher<Integer> createErrorStatePublisher() {
-    // Not sure what this is for yet
-    null
+    throttle(new Publisher<Integer>() {
+      @Override
+      void subscribe(Subscriber<? super Integer> s) {
+        s.onError(new RuntimeException("Can't subscribe subcriber: " + s + ", because of reasons."));
+      }
+    })
   }
 }