Package org.reactivestreams.tck.flow

Class FlowSubscriberBlackboxVerification<T>

  • All Implemented Interfaces:
    SubscriberBlackboxVerificationRules
    public abstract class FlowSubscriberBlackboxVerification<T>
extends SubscriberBlackboxVerification<T>
implements SubscriberBlackboxVerificationRules
    Provides tests for verifying Flow.Subscriber and Flow.Subscription specification rules, without any modifications to the tested implementation (also known as "Black Box" testing). This verification is NOT able to check many of the rules of the spec, and if you want more verification of your implementation you'll have to implement org.reactivestreams.tck.SubscriberWhiteboxVerification instead.
    See Also:
    Flow.Subscriber, Flow.Subscription

    • Constructor Detail

      • FlowSubscriberBlackboxVerification

        protected FlowSubscriberBlackboxVerification​(TestEnvironment env)

    • Method Detail

      • triggerFlowRequest

        public void triggerFlowRequest​(java.util.concurrent.Flow.Subscriber<? super T> subscriber)
        Override this method if the Flow.Subscriber implementation you are verifying needs an external signal before it signals demand to its Publisher. By default this method does nothing.

      • createFlowSubscriber

        public abstract java.util.concurrent.Flow.Subscriber<T> createFlowSubscriber()
        This is the main method you must implement in your test incarnation. It must create a new Flow.Subscriber instance to be subjected to the testing logic.