Transfers/copies all test annotations from the Publisher/Subscriber Verifications

to the IdentityProcessor-verification so that they are applied for the delegation.

Introduces SubscriberWhiteboxVerificationRules, SubscriberBlackboxVerificationRules and
PubisherVerificationRules to keep track of and assist in making sure that all tests
propagate properly between Subscriber, Publisher and Processor.

Author: viktorklang

examples/src/test/java/org/reactivestreams/example/unicast/AsyncSubscriberTest.java

@@ -60,7 +60,7 @@ public AsyncSubscriberTest() {
       }
     };
 
-    new NumberIterablePublisher<Integer>(0, 10, e).subscribe(sub);
+    new NumberIterablePublisher(0, 10, e).subscribe(sub);
     latch.await(DefaultTimeoutMillis * 10, TimeUnit.MILLISECONDS);
     assertEquals(i.get(), 45);
   }

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

@@ -13,23 +13,23 @@ private Annotations() {}
    * For example tests like "Publisher SHOULD consider Subscription as ..." - is inherently hard to specifically test.
    */
   @Target(ElementType.METHOD)
-  @Retention(RetentionPolicy.SOURCE)
+  @Retention(RetentionPolicy.RUNTIME)
   static @interface NotVerified {
   }
 
   /**
    * Used to mark stochastic tests which MAY yield false positives (pass) can violate the tested rule in some specific scenario.
    */
   @Target(ElementType.METHOD)
-  @Retention(RetentionPolicy.SOURCE)
+  @Retention(RetentionPolicy.RUNTIME)
   static @interface Stochastic {
   }
 
   /**
    * Used to mark tests that MUST pass in all (even very restricted types of) Publishers / Subscribers.
    */
   @Target(ElementType.METHOD)
-  @Retention(RetentionPolicy.SOURCE)
+  @Retention(RetentionPolicy.RUNTIME)
   static @interface Required {
   }
 
@@ -38,7 +38,7 @@ private Annotations() {}
    * If an implementation declares it does not support enough subscribers as needed by such test, it will be SKIPPed instead of FAILed.
    */
   @Target(ElementType.METHOD)
-  @Retention(RetentionPolicy.SOURCE)
+  @Retention(RetentionPolicy.RUNTIME)
   static @interface Subscribers {
     long value() default 1;
   }
@@ -48,7 +48,7 @@ private Annotations() {}
    * These tests can be skipped by returning null from the given factory method.
    */
   @Target(ElementType.METHOD)
-  @Retention(RetentionPolicy.SOURCE)
+  @Retention(RetentionPolicy.RUNTIME)
   static @interface Additional {
     /** Description of situation when it's OK to not pass this test */
     String value() default "";