vertx / io.vertx.ext.sync / Sync / streamAdaptor

streamAdaptor

@Suspendable open static fun <T : Any> streamAdaptor(): HandlerReceiverAdaptor<T>

Create an adaptor that converts a stream of events from a handler into a receiver which allows the events to be received synchronously.

Parameters

- the type of the event

Return
the adaptor

@Suspendable open static fun <T : Any> streamAdaptor(channel: Channel<T>): HandlerReceiverAdaptor<T>

Like #streamAdaptor() but using the specified Quasar `Channel` instance. This is useful if you want to fine-tune the behaviour of the adaptor.

Parameters

channel - the Quasar channel

- the type of the event

Return
the adaptor