Class TestSubscriber.Probe<T>

    • Method Detail

      • ensureSubscription

        public TestSubscriber.Probe<T> ensureSubscription()
        Asserts that a subscription has been received or will be received
      • requestNext

        public TestSubscriber.Probe<T> requestNext​(T element)
        Request and expect a stream element.
      • requestNext

        public T requestNext()
        Request and expect a stream element.
      • requestNext

        public T requestNext​(scala.concurrent.duration.FiniteDuration d)
        Request and expect a stream element during the specified time or timeout.