Class IdentityProcessorVerification.TestSetup

    • Constructor Detail

      • TestSetup

        public TestSetup​(TestEnvironment env,
                         int testBufferSize)
                  throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
    • Method Detail

      • nextT

        public T nextT()
                throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • expectNextElement

        public void expectNextElement​(TestEnvironment.ManualSubscriber<T> sub,
                                      T expected)
                               throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • expectNextElement

        public void expectNextElement​(TestEnvironment.ManualSubscriber<T> sub,
                                      T expected,
                                      java.lang.String errorMessageAddendum)
                               throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • sendNextTFromUpstream

        public T sendNextTFromUpstream()
                                throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException