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.
        Returns:
        (undocumented)
      • lazyEmpty

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

        public <T> org.reactivestreams.Publisher<T> error​(java.lang.Throwable cause)
        Publisher that signals error to subscribers immediately after handing out subscription.
        Parameters:
        cause - (undocumented)
        Returns:
        (undocumented)
      • lazyError

        public <T> org.reactivestreams.Publisher<T> lazyError​(java.lang.Throwable cause)
        Publisher that subscribes the subscriber and signals error after the first request.
        Parameters:
        cause - (undocumented)
        Returns:
        (undocumented)
      • manualProbe

        public <T> TestPublisher.ManualProbe<T> manualProbe​(boolean autoOnSubscribe,
                                                            ActorSystem system)
        Probe that implements Publisher interface.
        Parameters:
        autoOnSubscribe - (undocumented)
        system - (undocumented)
        Returns:
        (undocumented)
      • 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.
        Parameters:
        initialPendingRequests - (undocumented)
        system - (undocumented)
        Returns:
        (undocumented)
      • probe$default$1

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