Tune completeImmediatly to allow 3.2 in concurrent settings

Author: ktoso

tck/src/main/java/org/reactivestreams/tck/PublisherVerification.java

@@ -489,7 +489,7 @@ public void run(Publisher<T> pub) throws Throwable {
         ManualSubscriber<T> sub = new ManualSubscriber<T>(env) {
           @Override
           public void onSubscribe(Subscription subs) {
-            this.subscription.complete(subs);
+            this.subscription.completeImmediatly(subs);
 
             subs.request(1);
             subs.request(1);
@@ -505,7 +505,8 @@ public void onNext(T element) {
 
         env.subscribe(pub, sub);
 
-        env.verifyNoAsyncErrors();
+        long delay = env.defaultTimeoutMillis();
+        env.verifyNoAsyncErrors(delay);
       }
     });
   }
@@ -514,7 +515,7 @@ public void onNext(T element) {
   @Required @Test
   @Additional(implement = "boundedDepthOfOnNextAndRequestRecursion")
   public void spec303_mustNotAllowUnboundedRecursion() throws Throwable {
-    long oneMoreThanBoundedLimit = boundedDepthOfOnNextAndRequestRecursion() + 1;
+    final long oneMoreThanBoundedLimit = boundedDepthOfOnNextAndRequestRecursion() + 1;
 
     activePublisherTest(oneMoreThanBoundedLimit, new PublisherTestRun<T>() {
       @Override

tck/src/main/java/org/reactivestreams/tck/TestEnvironment.java

@@ -605,7 +605,7 @@ public Promise(TestEnvironment env) {
     }
 
     private ArrayBlockingQueue<T> abq = new ArrayBlockingQueue<T>(1);
-    volatile private T _value = null;
+    private volatile T _value = null;
 
     public T value() {
       if (isCompleted()) {
@@ -632,7 +632,8 @@ public void complete(T value) {
      * Completes the promise right away, it is not possible to expectCompletion on a Promise completed this way
      */
     public void completeImmediatly(T value) {
-      _value = value;
+      complete(value); // complete!
+      _value = value;  // immediatly!
     }
 
     public void expectCompletion(long timeoutMillis, String errorMsg) throws InterruptedException {