interface GrpcUniExchange<O : Any, I : Any> : GrpcWriteStream<O>
Author
Paulo Lopes
open static fun <O : Any, I : Any> create(read: GrpcReadStream<I>, write: StreamObserver<O>): GrpcUniExchange<O, I> |
|
abstract fun drainHandler(handler: Handler<Void>): GrpcUniExchange<O, I> |
|
abstract fun fail(t: Throwable): GrpcUniExchange<O, I> |
|
abstract fun handler(handler: Handler<AsyncResult<I>>): GrpcUniExchange<O, I> |
|
abstract fun setWriteQueueMaxSize(maxSize: Int): GrpcUniExchange<O, I> |
|
abstract fun write(data: O): GrpcUniExchange<O, I> |
|
abstract fun writeObserver(): StreamObserver<O> |
abstract fun exceptionHandler(handler: Handler<Throwable>): GrpcWriteStream<T>
Set an exception handler on the write stream. |