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>`