Package org.apache.pekko.stream.testkit

Class TestPublisher$

  • public class TestPublisher$
extends java.lang.Object
    Provides factory methods for various Publishers.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static TestPublisher$ MODULE$
      Static reference to the singleton instance of this Scala object.

    • Constructor Summary

      Constructors 
      Constructor Description
      TestPublisher$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> org.reactivestreams.Publisher<T> empty()
      Publisher that signals complete to subscribers, after handing a void subscription.
      <T> org.reactivestreams.Publisher<T> error​(java.lang.Throwable cause)
      Publisher that signals error to subscribers immediately after handing out subscription.
      <T> org.reactivestreams.Publisher<T> lazyEmpty()
      Publisher that subscribes the subscriber and completes after the first request.
      <T> org.reactivestreams.Publisher<T> lazyError​(java.lang.Throwable cause)
      Publisher that subscribes the subscriber and signals error after the first request.
      <T> TestPublisher.ManualProbe<T> manualProbe​(boolean autoOnSubscribe, ActorSystem system)
      Probe that implements Publisher interface.
      <T> boolean manualProbe$default$1()  
      <T> TestPublisher.Probe<T> probe​(long initialPendingRequests, ActorSystem system)
      Probe that implements Publisher interface and tracks demand.
      <T> long probe$default$1()  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • MODULE$

        public static final TestPublisher$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • TestPublisher$

        public TestPublisher$()

    • Method Detail

      • empty

        public <T> org.reactivestreams.Publisher<T> empty()
        Publisher that signals complete to subscribers, after handing a void subscription.

      • lazyEmpty

        public <T> org.reactivestreams.Publisher<T> lazyEmpty()
        Publisher that subscribes the subscriber and completes after the first request.

      • error

        public <T> org.reactivestreams.Publisher<T> error​(java.lang.Throwable cause)
        Publisher that signals error to subscribers immediately after handing out subscription.

      • lazyError

        public <T> org.reactivestreams.Publisher<T> lazyError​(java.lang.Throwable cause)
        Publisher that subscribes the subscriber and signals error after the first request.

      • manualProbe$default$1

        public <T> boolean manualProbe$default$1()

      • probe

        public <T> TestPublisher.Probe<T> probe​(long initialPendingRequests,
                                        ActorSystem system)
        Probe that implements Publisher interface and tracks demand.

      • probe$default$1

        public <T> long probe$default$1()