Class TestEnvironment.Receptacle<T>

  • Enclosing class:
    TestEnvironment

    public static class TestEnvironment.Receptacle<T>
    extends java.lang.Object
    • Method Detail

      • add

        public void add​(T value)
      • complete

        public void complete()
      • next

        public T next​(long timeoutMillis,
                      java.lang.String errorMsg)
               throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • nextOrEndOfStream

        public Optional<T> nextOrEndOfStream​(long timeoutMillis,
                                             java.lang.String errorMsg)
                                      throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • nextN

        public java.util.List<T> nextN​(long elements,
                                       long timeoutMillis,
                                       java.lang.String errorMsg)
                                throws java.lang.InterruptedException
        Parameters:
        timeoutMillis - total timeout time for awaiting all elements number of elements
        Throws:
        java.lang.InterruptedException
      • expectCompletion

        public void expectCompletion​(long timeoutMillis,
                                     java.lang.String errorMsg)
                              throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • expectError

        @Deprecated
        public <E extends java.lang.Throwable> E expectError​(java.lang.Class<E> clazz,
                                                             long timeoutMillis,
                                                             java.lang.String errorMsg)
                                                      throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • expectError

        final <E extends java.lang.Throwable> E expectError​(java.lang.Class<E> clazz,
                                                            long totalTimeoutMillis,
                                                            long pollTimeoutMillis,
                                                            java.lang.String errorMsg)
                                                     throws java.lang.Exception
        Throws:
        java.lang.Exception
      • expectNone

        public void expectNone​(long withinMillis,
                               java.lang.String errorMsgPrefix)
                        throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException