Package org.apache.pekko.stream.testkit

Class TestPublisher$

java.lang.Object
org.apache.pekko.stream.testkit.TestPublisher$
public class TestPublisher$ extends Object
Provides factory methods for various Publishers.

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestPublisher$()
     

  • Method Summary

    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(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(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 Details

    • MODULE$

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

  • Constructor Details

    • TestPublisher$

      public TestPublisher$()

  • Method Details

    • 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(Throwable cause)
      Publisher that signals error to subscribers immediately after handing out subscription.

    • lazyError

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

    • manualProbe

      public <T> TestPublisher.ManualProbe<T> manualProbe(boolean autoOnSubscribe, ActorSystem system)
      Probe that implements Publisher interface.

    • 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()