Package org.reactivestreams.tck.flow

Class IdentityFlowProcessorVerification<T>

    • Constructor Detail

      • IdentityFlowProcessorVerification

        public IdentityFlowProcessorVerification​(TestEnvironment env)

      • IdentityFlowProcessorVerification

        public IdentityFlowProcessorVerification​(TestEnvironment env,
                                         long publisherReferenceGCTimeoutMillis)

      • IdentityFlowProcessorVerification

        public IdentityFlowProcessorVerification​(TestEnvironment env,
                                         long publisherReferenceGCTimeoutMillis,
                                         int processorBufferSize)

    • Method Detail

      • createFailedFlowPublisher

        protected abstract java.util.concurrent.Flow.Publisher<T> createFailedFlowPublisher()
        By implementing this method, additional TCK tests concerning a "failed" Flow publishers will be run. The expected behaviour of the Flow.Publisher returned by this method is hand out a subscription, followed by signalling onError on it, as specified by Rule 1.9. If you want to ignore these additional tests, return null from this method.

      • createIdentityFlowProcessor

        protected abstract java.util.concurrent.Flow.Processor<T,​T> createIdentityFlowProcessor​(int bufferSize)
        This is the main method you must implement in your test incarnation. It must create a Flow.Processor, which simply forwards all stream elements from its upstream to its downstream. It must be able to internally buffer the given number of elements.
        Parameters:
        bufferSize - number of elements the processor is required to be able to buffer.

      • createIdentityProcessor

        public final Processor<T,​T> createIdentityProcessor​(int bufferSize)
        Description copied from class: IdentityProcessorVerification
        This is the main method you must implement in your test incarnation. It must create a Processor, which simply forwards all stream elements from its upstream to its downstream. It must be able to internally buffer the given number of elements.
        Specified by:
        createIdentityProcessor in class IdentityProcessorVerification<T>
        Parameters:
        bufferSize - number of elements the processor is required to be able to buffer.

      • createFailedPublisher

        public final Publisher<T> createFailedPublisher()
        Description copied from class: IdentityProcessorVerification
        By implementing this method, additional TCK tests concerning a "failed" publishers will be run. The expected behaviour of the Publisher returned by this method is hand out a subscription, followed by signalling onError on it, as specified by Rule 1.9. If you want to ignore these additional tests, return null from this method.
        Specified by:
        createFailedPublisher in class IdentityProcessorVerification<T>