Class TestPublisher

Provides factory methods for various Publishers.

Inheritance
object
TestPublisher
Inherited Members
Namespace: Akka.Streams.TestKit
Assembly: Akka.Streams.TestKit.dll
Syntax
public static class TestPublisher

Methods

| Edit this page View Source

CreateManualPublisherProbe<T>(TestKitBase, bool)

Probe that implements Reactive.Streams.IPublisher{T} interface.

Declaration
public static TestPublisher.ManualProbe<T> CreateManualPublisherProbe<T>(this TestKitBase testKit, bool autoOnSubscribe = true)
Parameters
Type Name Description
TestKitBase testKit
bool autoOnSubscribe
Returns
Type Description
TestPublisher.ManualProbe<T>
Type Parameters
Name Description
T
| Edit this page View Source

CreatePublisherProbe<T>(TestKitBase, long)

Declaration
public static TestPublisher.Probe<T> CreatePublisherProbe<T>(this TestKitBase testKit, long initialPendingRequests = 0)
Parameters
Type Name Description
TestKitBase testKit
long initialPendingRequests
Returns
Type Description
TestPublisher.Probe<T>
Type Parameters
Name Description
T
| Edit this page View Source

Empty<T>()

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

Declaration
public static IPublisher<T> Empty<T>()
Returns
Type Description
IPublisher<T>
Type Parameters
Name Description
T
| Edit this page View Source

Error<T>(Exception)

Publisher that signals error to subscribers immediately after handing out subscription.

Declaration
public static IPublisher<T> Error<T>(Exception exception)
Parameters
Type Name Description
Exception exception
Returns
Type Description
IPublisher<T>
Type Parameters
Name Description
T
| Edit this page View Source

LazyEmpty<T>()

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

Declaration
public static IPublisher<T> LazyEmpty<T>()
Returns
Type Description
IPublisher<T>
Type Parameters
Name Description
T
| Edit this page View Source

LazyError<T>(Exception)

Publisher subscribes the subscriber and signals error after the first request.

Declaration
public static IPublisher<T> LazyError<T>(Exception exception)
Parameters
Type Name Description
Exception exception
Returns
Type Description
IPublisher<T>
Type Parameters
Name Description
T