=tck check isCancelled in 205 blackbox; sample the state sometimes

Author: ktoso

Diff for: tck/src/main/java/org/reactivestreams/tck/SubscriberBlackboxVerification.java

@@ -100,13 +100,22 @@ public void run(BlackboxTestStage stage) throws InterruptedException {
         final long signalsToEmit = Math.min(requested, 512); // protecting against Subscriber which sends ridiculous large demand
 
         // should cope with up to requested number of elements
-        for (int i = 0; i < signalsToEmit; i++)
+        for (int i = 0; i < signalsToEmit && sampleIsCancelled(stage, i, 10); i++)
           stage.signalNext();
 
         // we complete after `signalsToEmit` (which can be less than `requested`), 
         // which is legal under https://github.com/reactive-streams/reactive-streams-jvm#1.2
         stage.sendCompletion();
       }
+
+      /** 
+       * In order to allow some "skid" and not check state on each iteration, 
+       * only check {@code stage.isCancelled} every {@code checkInterval}'th iteration.
+       */
+      private boolean sampleIsCancelled(BlackboxTestStage stage, int i, int checkInterval) throws InterruptedException {
+        if (i % checkInterval == 0) return stage.isCancelled();
+        else return false;
+      }
     });
   }
 

Diff for: tck/src/main/java/org/reactivestreams/tck/TestEnvironment.java

@@ -775,6 +775,10 @@ public void expectCancelling() throws InterruptedException {
     public void expectCancelling(long timeoutMillis) throws InterruptedException {
       cancelled.expectClose(timeoutMillis, "Did not receive expected cancelling of upstream subscription");
     }
+    
+    public boolean isCancelled() throws InterruptedException {
+      return cancelled.isClosed();
+    }
   }
 
   /**