interface GrpcReadStream<T : Any> : ReadStream<T>
Author
Paulo Lopes
open static fun <T : Any> create(observer: StreamObserver<T>): GrpcReadStream<T>open static fun <T : Any> create(): GrpcReadStream<T> |
|
abstract fun endHandler(endHandler: Handler<Void>): GrpcReadStream<T>
Set an end handler. Once the stream has ended, and there is no more data to be read, this handler will be called. |
|
abstract fun exceptionHandler(handler: Handler<Throwable>): GrpcReadStream<T>
Set an exception handler on the read stream. |
|
abstract fun handler(handler: Handler<T>): GrpcReadStream<T>
Set a data handler. As data is read, the handler will be called with the data. |
|
abstract fun pause(): GrpcReadStream<T>
Pause the |
|
abstract fun readObserver(): StreamObserver<T>
Should not be used by end user, it is a simple accessor the the underlying gRPC StreamObserver. |
|
abstract fun resume(): GrpcReadStream<T>
Resume reading. If the |
|
abstract fun setReadObserver(observer: StreamObserver<T>): GrpcReadStream<T> |
interface GrpcBidiExchange<I : Any, O : Any> : GrpcReadStream<I>, GrpcWriteStream<O> |