interface GrpcBidiExchange<I : Any, O : Any> : GrpcReadStream<I>, GrpcWriteStream<O>
Author
Paulo Lopes
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> |
|
abstract fun drainHandler(handler: Handler<Void>): GrpcBidiExchange<I, O> |
|
abstract fun endHandler(handler: Handler<Void>): GrpcBidiExchange<I, O> |
|
abstract fun exceptionHandler(handler: Handler<Throwable>): GrpcBidiExchange<I, O> |
|
abstract fun fail(t: Throwable): GrpcBidiExchange<I, O> |
|
abstract fun handler(handler: Handler<I>): GrpcBidiExchange<I, O> |
|
abstract fun pause(): GrpcBidiExchange<I, O> |
|
abstract fun readObserver(): StreamObserver<I> |
|
abstract fun resume(): GrpcBidiExchange<I, O> |
|
abstract fun setReadObserver(observer: StreamObserver<I>): GrpcBidiExchange<I, O> |
|
abstract fun setWriteQueueMaxSize(maxSize: Int): GrpcBidiExchange<I, O> |
|
abstract fun write(data: O): GrpcBidiExchange<I, O> |
|
abstract fun writeObserver(): StreamObserver<O> |