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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestPublisher.CancelSubscription
static class	TestPublisher.CancelSubscription$
static class	TestPublisher.ManualProbe<I> Implementation of Publisher that allows various assertions.
static class	TestPublisher.ManualProbe$
static class	TestPublisher.Probe<T> Single subscription and demand tracking for TestPublisher.ManualProbe.
static interface	TestPublisher.PublisherEvent
static class	TestPublisher.RequestMore
static class	TestPublisher.RequestMore$
static class	TestPublisher.Subscribe
static class	TestPublisher.Subscribe$

Constructor Summary

Constructors

Constructor and Description
TestPublisher()

Method Summary

Modifier and Type	Method and Description
static <T> org.reactivestreams.Publisher<T>	empty() Publisher that signals complete to subscribers, after handing a void subscription.
static <T> org.reactivestreams.Publisher<T>	error(java.lang.Throwable cause) Publisher that signals error to subscribers immediately after handing out subscription.
static <T> org.reactivestreams.Publisher<T>	lazyEmpty() Publisher that subscribes the subscriber and completes after the first request.
static <T> org.reactivestreams.Publisher<T>	lazyError(java.lang.Throwable cause) Publisher that subscribes the subscriber and signals error after the first request.
static <T> TestPublisher.ManualProbe<T>	manualProbe(boolean autoOnSubscribe, ActorSystem system) Probe that implements Publisher interface.
static <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

Constructor Detail

TestPublisher

public TestPublisher()

Method Detail

empty

public static <T> org.reactivestreams.Publisher<T> empty()

Publisher that signals complete to subscribers, after handing a void subscription.

Returns:

(undocumented)

lazyEmpty

public static <T> org.reactivestreams.Publisher<T> lazyEmpty()

Publisher that subscribes the subscriber and completes after the first request.

Returns:

(undocumented)

error

public static <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 static <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 static <T> TestPublisher.ManualProbe<T> manualProbe(boolean autoOnSubscribe,
                                                           ActorSystem system)

Probe that implements Publisher interface.

Parameters:

autoOnSubscribe - (undocumented)

system - (undocumented)

Returns:

(undocumented)

probe

public static <T> TestPublisher.Probe<T> probe(long initialPendingRequests,
                                               ActorSystem system)

Probe that implements Publisher interface and tracks demand.

Parameters:

initialPendingRequests - (undocumented)

system - (undocumented)

Returns:

(undocumented)