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

| Improve this Doc View Source

CreateManualPublisherProbe<T>(TestKitBase, Boolean)

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
Boolean autoOnSubscribe
Returns
Type Description
TestPublisher.ManualProbe<T>
Type Parameters
Name Description
T
| Improve this Doc View Source

CreatePublisherProbe<T>(TestKitBase, Int64)

Declaration
public static TestPublisher.Probe<T> CreatePublisherProbe<T>(this TestKitBase testKit, long initialPendingRequests = 0L)
Parameters
Type Name Description
TestKitBase testKit
Int64 initialPendingRequests
Returns
Type Description
TestPublisher.Probe<T>
Type Parameters
Name Description
T
| Improve this Doc 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
Reactive.Streams.IPublisher<T>
Type Parameters
Name Description
T
| Improve this Doc 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
Reactive.Streams.IPublisher<T>
Type Parameters
Name Description
T
| Improve this Doc 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
Reactive.Streams.IPublisher<T>
Type Parameters
Name Description
T
| Improve this Doc 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
Reactive.Streams.IPublisher<T>
Type Parameters
Name Description
T