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

Packages that use MockIncoming

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

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

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

Modifier and Type	Method	Description
MockIncoming<P>	MockIncoming.awaitCancelled(Duration timeout)	Wait and block till the stream is in terminal state and asserts if the terminal state is caused by cancel signal.
MockIncoming<P>	MockIncoming.complete()	Send terminal complete signal to the channel.
final MockIncoming<P>	MockIncoming.emit(Message<P>... message)	Emit one or more messages directly to the mocked channel.
final MockIncoming<P>	MockIncoming.emit(P... payload)	Emit one or more payloads directly to the mocked channel.
MockIncoming<P>	MockIncoming.fail(Throwable t)	Send terminal error signal to the channel.
<P> MockIncoming<P>	MockConnector.incoming(String channelName, Class<P> type)	Retrieve mocker for incoming channel.