Class IdentityFlowProcessorVerification<T>

java.lang.Object
org.reactivestreams.tck.WithHelperPublisher<T>
org.reactivestreams.tck.IdentityProcessorVerification<T>
org.reactivestreams.tck.flow.IdentityFlowProcessorVerification<T>
All Implemented Interfaces:
PublisherVerificationRules, SubscriberWhiteboxVerificationRules

public abstract class IdentityFlowProcessorVerification<T> extends IdentityProcessorVerification<T> implements SubscriberWhiteboxVerificationRules, PublisherVerificationRules
  • Constructor Details

    • IdentityFlowProcessorVerification

      public IdentityFlowProcessorVerification(TestEnvironment env)
    • IdentityFlowProcessorVerification

      public IdentityFlowProcessorVerification(TestEnvironment env, long publisherReferenceGCTimeoutMillis)
    • IdentityFlowProcessorVerification

      public IdentityFlowProcessorVerification(TestEnvironment env, long publisherReferenceGCTimeoutMillis, int processorBufferSize)
  • Method Details

    • createFailedFlowPublisher

      protected abstract 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 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>