vertx / io.vertx.kotlin.coroutines / ReceiveChannelHandler

ReceiveChannelHandler

class ReceiveChannelHandler<T> : ReceiveChannel<T>, Handler<T>

An adapter that converts a stream of events from the Handler into a ReceiveChannel which allows the events to be received synchronously.

Constructors

<init>

ReceiveChannelHandler(vertx: Vertx)ReceiveChannelHandler(context: Context)

An adapter that converts a stream of events from the Handler into a ReceiveChannel which allows the events to be received synchronously.

Properties

isClosedForReceive

val isClosedForReceive: Boolean

isEmpty

val isEmpty: Boolean

onReceive

val onReceive: SelectClause1<T>

onReceiveOrNull

val onReceiveOrNull: SelectClause1<T?>

Functions

handle

fun handle(event: T): Unit

iterator

fun iterator(): ChannelIterator<T>

poll

fun poll(): T?

receive

suspend fun receive(): T

receiveOrNull

suspend fun receiveOrNull(): T?