Class TestPublisher.Probe<T>

    • Constructor Detail

      • Probe

        public Probe​(long initialPendingRequests,
                     ActorSystem system)
    • Method Detail

      • ensureSubscription

        public void ensureSubscription()
        Asserts that a subscription has been received or will be received
      • expectCancellationWithCause

        public TestPublisher.Probe<T> expectCancellationWithCause​(java.lang.Throwable expectedCause)
      • expectCancellationWithCause

        public <E extends java.lang.Throwable> E expectCancellationWithCause​(scala.reflect.ClassTag<E> evidence$1)
      • expectCancellationWithCause

        public <E extends java.lang.Throwable> E expectCancellationWithCause​(java.lang.Class<E> causeClass)
        Java API
      • expectRequest

        public long expectRequest()
      • pending

        public long pending()
        Current pending requests.