Merge pull request reactive-streams#222 from reactive-streams/wip-212-double-subscription-processor-spec-213

fix reactive-streams#212 issue on spec 213 testing wrt Processor

Author: smaldini

build.gradle

@@ -3,7 +3,7 @@ subprojects {
     apply plugin: "osgi"
 
     group = "org.reactivestreams"
-    version = "1.0.0.RC2"
+    version = "1.0.0.RC3.BUILD-SNAPSHOT"
 
     sourceCompatibility = 1.6
     targetCompatibility = 1.6

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

@@ -349,11 +349,11 @@ public void required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParame
       public void run(WhiteboxTestStage stage) throws Throwable {
 
         {
-          final Subscriber<T> sub = createSubscriber(stage.probe());
+          final Subscriber<? super T> sub = stage.sub();
           boolean gotNPE = false;
           try {
             sub.onSubscribe(null);
-          } catch(final NullPointerException expected) {
+          } catch (final NullPointerException expected) {
             gotNPE = true;
           }
           assertTrue(gotNPE, "onSubscribe(null) did not throw NullPointerException");
@@ -370,17 +370,22 @@ public void required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersA
       public void run(WhiteboxTestStage stage) throws Throwable {
 
         final Subscription subscription = new Subscription() {
-          @Override public void request(final long elements) {}
-          @Override public void cancel() {}
+          @Override
+          public void request(final long elements) {
+          }
+
+          @Override
+          public void cancel() {
+          }
         };
 
         {
-          final Subscriber<T> sub = createSubscriber(stage.probe());
+          final Subscriber<? super T> sub = stage.sub();
           boolean gotNPE = false;
           sub.onSubscribe(subscription);
           try {
             sub.onNext(null);
-          } catch(final NullPointerException expected) {
+          } catch (final NullPointerException expected) {
             gotNPE = true;
           }
           assertTrue(gotNPE, "onNext(null) did not throw NullPointerException");
@@ -390,7 +395,7 @@ public void run(WhiteboxTestStage stage) throws Throwable {
       }
     });
   }
-  
+
   // Verifies rule: https://github.com/reactive-streams/reactive-streams#2.13
   @Override @Test
   public void required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull() throws Throwable {
@@ -399,17 +404,22 @@ public void required_spec213_onError_mustThrowNullPointerExceptionWhenParameters
       public void run(WhiteboxTestStage stage) throws Throwable {
 
         final Subscription subscription = new Subscription() {
-          @Override public void request(final long elements) {}
-          @Override public void cancel() {}
+          @Override
+          public void request(final long elements) {
+          }
+
+          @Override
+          public void cancel() {
+          }
         };
 
         {
-          final Subscriber<T> sub = createSubscriber(stage.probe());
+          final Subscriber<? super T> sub = stage.sub();
           boolean gotNPE = false;
           sub.onSubscribe(subscription);
           try {
             sub.onError(null);
-          } catch(final NullPointerException expected) {
+          } catch (final NullPointerException expected) {
             gotNPE = true;
           }
           assertTrue(gotNPE, "onError(null) did not throw NullPointerException");