Uses of Class
io.helidon.messaging.connectors.mock.MockOutgoing

Packages that use MockOutgoing

Package	Description
io.helidon.messaging.connectors.mock	Helidon messaging mock connector for testing purposes.

Uses of MockOutgoing in io.helidon.messaging.connectors.mock

Methods in io.helidon.messaging.connectors.mock that return MockOutgoing

Modifier and Type	Method	Description
<T> MockOutgoing<P>	MockOutgoing.assertData(Function<Message<P>,P> mapper, org.hamcrest.Matcher<? super T> matcher)	Assert if matching data has been received.
final MockOutgoing<P>	MockOutgoing.assertData(Function<Message<P>,P> mapper, P... items)	Assert if matching messages has been received.
<T> MockOutgoing<P>	MockOutgoing.assertPayloads(org.hamcrest.Matcher<? super T> matcher)	Assert if matching payloads has been received.
final MockOutgoing<P>	MockOutgoing.assertPayloads(P... expected)	Assert if matching payloads has been received.
MockOutgoing<P>	MockOutgoing.awaitComplete(Duration timeout)	Block current thread until channel gets terminated with complete signal.
MockOutgoing<P>	MockOutgoing.awaitCount(Duration timeout, int count)	Block current thread until expected number of items is received.
MockOutgoing<P>	MockOutgoing.awaitData(Duration timeout, Function<Message<P>,P> mapper, P... expectedItems)	Block current thread until expected messages are received.
MockOutgoing<P>	MockOutgoing.awaitMessage(Duration timeout, Function<Message<P>,Boolean> waitingFor)	Block current thread until expected message is received.
final MockOutgoing<P>	MockOutgoing.awaitPayloads(Duration timeout, P... expectedItems)	Block current thread until expected payloads are received.
<P> MockOutgoing<P>	MockConnector.outgoing(String channelName, Class<P> type)	Retrieve mocker for outgoing channel.
MockOutgoing<P>	MockOutgoing.request(long n)	Control backpressure manually and request n items from upstream.
MockOutgoing<P>	MockOutgoing.requestMax()	Request unbounded number of items from upstream and effectively turn off backpressure.