vertx / io.vertx.grpc / GrpcUniExchange

GrpcUniExchange

interface GrpcUniExchange<O : Any, I : Any> : GrpcWriteStream<O>

Author
Paulo Lopes

Functions

create

open static fun <O : Any, I : Any> create(read: GrpcReadStream<I>, write: StreamObserver<O>): GrpcUniExchange<O, I>

drainHandler

abstract fun drainHandler(handler: Handler<Void>): GrpcUniExchange<O, I>

fail

abstract fun fail(t: Throwable): GrpcUniExchange<O, I>

handler

abstract fun handler(handler: Handler<AsyncResult<I>>): GrpcUniExchange<O, I>

setWriteQueueMaxSize

abstract fun setWriteQueueMaxSize(maxSize: Int): GrpcUniExchange<O, I>

write

abstract fun write(data: O): GrpcUniExchange<O, I>

writeObserver

abstract fun writeObserver(): StreamObserver<O>

Inherited Functions

exceptionHandler

abstract fun exceptionHandler(handler: Handler<Throwable>): GrpcWriteStream<T>

Set an exception handler on the write stream.