GrpcWriteStream (Vert.x gRPC 5.0.5 API)

java.lang.Object
- io.vertx.grpc.stub.GrpcWriteStream<T>

All Implemented Interfaces:: StreamBase, WriteStream<T>

public class GrpcWriteStream<T>
extends Object
implements WriteStream<T>

Author:: ecatala

Constructor Summary

Constructors
Constructor Description

GrpcWriteStream(io.grpc.stub.StreamObserver<T> observer)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`WriteStream<T>`	`drainHandler(Handler<Void> hndlr)`
`Future<Void>`	`end()`
`WriteStream<T>`	`exceptionHandler(Handler<Throwable> hndlr)`
`WriteStream<T>`	`setWriteQueueMaxSize(int i)`
`io.grpc.stub.StreamObserver<T>`	`streamObserver()`	Low level control of the observer for advanced use cases.
`Future<Void>`	`write(T data)`
`boolean`	`writeQueueFull()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.vertx.core.streams.WriteStream
end

- Constructor Detail
  - GrpcWriteStream
```
public GrpcWriteStream(io.grpc.stub.StreamObserver<T> observer)
```
- Method Detail
  - exceptionHandler
```
public WriteStream<T> exceptionHandler(Handler<Throwable> hndlr)
```
    Specified by:
    
    exceptionHandler in interface StreamBase
    
    Specified by:
    
    exceptionHandler in interface WriteStream<T>
  - write
```
public Future<Void> write(T data)
```
    Specified by:
    
    write in interface WriteStream<T>
  - end
```
public Future<Void> end()
```
    Specified by:
    
    end in interface WriteStream<T>
  - setWriteQueueMaxSize
```
public WriteStream<T> setWriteQueueMaxSize(int i)
```
    Specified by:
    
    setWriteQueueMaxSize in interface WriteStream<T>
  - writeQueueFull
```
public boolean writeQueueFull()
```
    Specified by:
    
    writeQueueFull in interface WriteStream<T>
  - drainHandler
```
public WriteStream<T> drainHandler(Handler<Void> hndlr)
```
    Specified by:
    
    drainHandler in interface WriteStream<T>
  - streamObserver
```
public io.grpc.stub.StreamObserver<T> streamObserver()
```
    Low level control of the observer for advanced use cases.