vertx / io.vertx.grpc / GrpcBidiExchange

GrpcBidiExchange

interface GrpcBidiExchange<I : Any, O : Any> : GrpcReadStream<I>, GrpcWriteStream<O>

Author
Paulo Lopes

Functions

create

open static fun <I : Any, O : Any> create(readStream: GrpcReadStream<I>, writeObserver: StreamObserver<O>): GrpcBidiExchange<I, O>
open static fun <I : Any, O : Any> create(readObserver: StreamObserver<I>, writeObserver: StreamObserver<O>): GrpcBidiExchange<I, O>

drainHandler

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

endHandler

abstract fun endHandler(handler: Handler<Void>): GrpcBidiExchange<I, O>

exceptionHandler

abstract fun exceptionHandler(handler: Handler<Throwable>): GrpcBidiExchange<I, O>

fail

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

handler

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

pause

abstract fun pause(): GrpcBidiExchange<I, O>

readObserver

abstract fun readObserver(): StreamObserver<I>

resume

abstract fun resume(): GrpcBidiExchange<I, O>

setReadObserver

abstract fun setReadObserver(observer: StreamObserver<I>): GrpcBidiExchange<I, O>

setWriteQueueMaxSize

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

write

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

writeObserver

abstract fun writeObserver(): StreamObserver<O>