| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
AmqpSender
AMQP Sender interface used to send messages. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
WriteStream<Buffer> | 
DatagramSocket.sender(int port,
      String host)
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
MessageProducer<T>
Represents a stream of message that can be written to. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
AsyncFile
Represents a file on the file-system which can be read from, or written to asynchronously. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
HttpClientRequest
Represents a client-side HTTP request. 
 | 
interface  | 
HttpServerResponse
Represents a server-side HTTP response. 
 | 
interface  | 
ServerWebSocket
Represents a server side WebSocket. 
 | 
interface  | 
WebSocket
Represents a client-side WebSocket. 
 | 
interface  | 
WebSocketBase
Base WebSocket implementation. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
NetSocket
Represents a socket-like interface to a TCP connection on either the
 client or the server side. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T> Pump | 
PumpFactory.pump(ReadStream<T> rs,
    WriteStream<T> ws)  | 
<T> Pump | 
PumpFactory.pump(ReadStream<T> rs,
    WriteStream<T> ws,
    int writeQueueMaxSize)  | 
| Modifier and Type | Method and Description | 
|---|---|
WriteStream<T> | 
WriteStream.drainHandler(Handler<Void> handler)
Set a drain handler on the stream. 
 | 
WriteStream<T> | 
WriteStream.exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the write stream. 
 | 
WriteStream<T> | 
WriteStream.setWriteQueueMaxSize(int maxSize)
Set the maximum size of the write queue to  
maxSize. | 
WriteStream<T> | 
WriteStream.write(T data)
Write some data to the stream. 
 | 
WriteStream<T> | 
WriteStream.write(T data,
     Handler<AsyncResult<Void>> handler)
Same as  
#write(T) but with an handler called when the operation completes | 
| Modifier and Type | Method and Description | 
|---|---|
default void | 
ReadStream.pipeTo(WriteStream<T> dst)
Like  
ReadStream.pipeTo(WriteStream, Handler) but with no completion handler. | 
default void | 
ReadStream.pipeTo(WriteStream<T> dst,
      Handler<AsyncResult<Void>> handler)
Pipe this  
ReadStream to the WriteStream. | 
static <T> Pump | 
Pump.pump(ReadStream<T> rs,
    WriteStream<T> ws)
Create a new  
Pump with the given ReadStream and WriteStream | 
static <T> Pump | 
Pump.pump(ReadStream<T> rs,
    WriteStream<T> ws,
    int writeQueueMaxSize)
Create a new  
Pump with the given ReadStream and WriteStream and
 writeQueueMaxSize | 
void | 
Pipe.to(WriteStream<T> dst)
Like  
Pipe.to(WriteStream, Handler) but without a completion handler | 
void | 
Pipe.to(WriteStream<T> dst,
  Handler<AsyncResult<Void>> completionHandler)
Start to pipe the elements to the destination  
WriteStream. | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ReactiveWriteStream<T>
A Vert.x write stream that also implements reactive streams publisher interface. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static BodyCodec<Void> | 
BodyCodec.pipe(WriteStream<Buffer> stream)
A body codec that pipes the body to a write stream. 
 | 
static BodyCodec<Void> | 
BodyCodec.pipe(WriteStream<Buffer> stream,
    boolean close)
A body codec that pipes the body to a write stream. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
BodyStream<T>
The body stream decodes a  
WriteStream into the a T instance. | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
SockJSSocket
You interact with SockJS clients through instances of SockJS socket. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
GrpcBidiExchange<I,O>  | 
interface  | 
GrpcUniExchange<O,I>  | 
interface  | 
GrpcWriteStream<T>  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
KafkaProducer<K,V>
Vert.x Kafka producer. 
 | 
interface  | 
KafkaWriteStream<K,V>
A  
WriteStream for writing to Kafka ProducerRecord. | 
| Modifier and Type | Method and Description | 
|---|---|
WriteStream | 
WriteStream.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> WriteStream<T> | 
WriteStream.newInstance(WriteStream arg)  | 
static <T> WriteStream<T> | 
WriteStream.newInstance(WriteStream arg,
           io.vertx.lang.rx.TypeArg<T> __typeArg_T)  | 
| Modifier and Type | Method and Description | 
|---|---|
WriteStream | 
WriteStream.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> WriteStream<T> | 
WriteStream.newInstance(WriteStream arg)  | 
static <T> WriteStream<T> | 
WriteStream.newInstance(WriteStream arg,
           io.vertx.lang.rx.TypeArg<T> __typeArg_T)  | 
Copyright © 2020 Eclipse. All rights reserved.