akka.stream.testkit

Class TestPublisher$

java.lang.Object

akka.stream.testkit.TestPublisher$

public class TestPublisher$
extends java.lang.Object

Provides factory methods for various Publishers.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestPublisher$()

Method Summary

Modifier and Type	Method and 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> TestPublisher.Probe<T>	probe(long initialPendingRequests, ActorSystem system) Probe that implements Publisher interface and tracks demand.

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)

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)