public interface GrpcReadStream<T>
extends io.vertx.core.streams.ReadStream<T>
Modifier and Type | Method and Description |
---|---|
static <T> GrpcReadStream<T> |
create() |
static <T> GrpcReadStream<T> |
create(io.grpc.stub.StreamObserver<T> observer) |
GrpcReadStream<T> |
endHandler(io.vertx.core.Handler<Void> endHandler)
Set an end handler.
|
GrpcReadStream<T> |
exceptionHandler(io.vertx.core.Handler<Throwable> handler)
Set an exception handler on the read stream.
|
GrpcReadStream<T> |
handler(io.vertx.core.Handler<T> handler)
Set a data handler.
|
GrpcReadStream<T> |
pause()
Pause the
ReadSupport . |
io.grpc.stub.StreamObserver<T> |
readObserver()
Should not be used by end user, it is a simple accessor the the underlying gRPC StreamObserver.
|
GrpcReadStream<T> |
resume()
Resume reading.
|
GrpcReadStream<T> |
setReadObserver(io.grpc.stub.StreamObserver<T> observer) |
static <T> GrpcReadStream<T> create(io.grpc.stub.StreamObserver<T> observer)
static <T> GrpcReadStream<T> create()
GrpcReadStream<T> exceptionHandler(io.vertx.core.Handler<Throwable> handler)
exceptionHandler
in interface io.vertx.core.streams.ReadStream<T>
exceptionHandler
in interface io.vertx.core.streams.StreamBase
handler
- the exception handlerGrpcReadStream<T> handler(io.vertx.core.Handler<T> handler)
handler
in interface io.vertx.core.streams.ReadStream<T>
GrpcReadStream<T> pause()
ReadSupport
. While it's paused, no data will be sent to the dataHandler
pause
in interface io.vertx.core.streams.ReadStream<T>
GrpcReadStream<T> resume()
ReadSupport
has been paused, reading will recommence on it.resume
in interface io.vertx.core.streams.ReadStream<T>
GrpcReadStream<T> endHandler(io.vertx.core.Handler<Void> endHandler)
endHandler
in interface io.vertx.core.streams.ReadStream<T>
io.grpc.stub.StreamObserver<T> readObserver()
GrpcReadStream<T> setReadObserver(io.grpc.stub.StreamObserver<T> observer)
Copyright © 2018 Eclipse. All rights reserved.