Package org.apache.pekko.stream.testkit
package org.apache.pekko.stream.testkit
-
ClassDescriptionMessages emitted after the corresponding
stageUnderTestmethods has been invoked.Sent to the probe when the operator callback threw an exception param: operation The operation that failedMessages emitted after the correspondingstageUnderTestmethods has been invoked.INTERNAL APIINTERNAL APIProvides factory methods for various Publishers.Single subscription and demand tracking forTestPublisher.ManualProbe.Provides factory methods for various Publishers.Implementation ofSubscriberthat allows various assertions.Single subscription tracking forTestSubscriber.ManualProbe.