![]() | TestPublisher Class |
Namespace: Akka.Streams.TestKit
The TestPublisher type exposes the following members.
Name | Description | |
---|---|---|
![]() ![]() | CreateManualPublisherProbe<T> |
Probe that implements IPublisher interface.
|
![]() ![]() | CreatePublisherProbe<T> | |
![]() ![]() | Empty<T> |
Publisher that signals complete to subscribers, after handing a void subscription.
|
![]() ![]() | Error<T> |
Publisher that signals error to subscribers immediately after handing out subscription.
|
![]() ![]() | LazyEmpty<T> |
Publisher that subscribes the subscriber and completes after the first request.
|
![]() ![]() | LazyError<T> |
Publisher subscribes the subscriber and signals error after the first request.
|