Class TestEnvironment.Receptacle<T>

    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      void add​(T value)  
      void complete()  
      void expectCompletion​(long timeoutMillis, java.lang.String errorMsg)  
      <E extends java.lang.Throwable>
      E
      expectError​(java.lang.Class<E> clazz, long timeoutMillis, java.lang.String errorMsg)
      Deprecated.
      void expectNone​(long withinMillis, java.lang.String errorMsgPrefix)  
      T next​(long timeoutMillis, java.lang.String errorMsg)  
      java.util.List<T> nextN​(long elements, long timeoutMillis, java.lang.String errorMsg)  
      Optional<T> nextOrEndOfStream​(long timeoutMillis, java.lang.String errorMsg)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • add

        public void add​(T value)
      • next

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

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

        public java.util.List<TnextN​(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
      • expectNone

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