| Modifier and Type | Method and Description |
|---|---|
Buffer |
AmqpMessage.bodyAsBinary() |
| Modifier and Type | Method and Description |
|---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.withBufferAsBody(Buffer buffer) |
| Modifier and Type | Method and Description |
|---|---|
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(Class<T> mappedType) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(Class<T> mappedType) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(Class<T> mappedType) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(Class<T> mappedType) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
| Modifier and Type | Field and Description |
|---|---|
static io.vertx.lang.rx.TypeArg<Buffer> |
Buffer.__TYPE_ARG |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
Buffer.appendBuffer(Buffer buff)
Appends the specified
Buffer to the end of this Buffer. |
Buffer |
Buffer.appendBuffer(Buffer buff,
int offset,
int len)
Appends the specified
Buffer starting at the offset using len to the end of this Buffer. |
Buffer |
Buffer.appendByte(byte b)
Appends the specified
byte to the end of the Buffer. |
Buffer |
Buffer.appendBytes(byte[] bytes)
Appends the specified
byte[] to the end of the Buffer. |
Buffer |
Buffer.appendBytes(byte[] bytes,
int offset,
int len)
Appends the specified number of bytes from
byte[] to the end of the Buffer, starting at the given offset. |
Buffer |
Buffer.appendDouble(double d)
Appends the specified
double to the end of the Buffer. |
Buffer |
Buffer.appendFloat(float f)
Appends the specified
float to the end of the Buffer. |
Buffer |
Buffer.appendInt(int i)
Appends the specified
int to the end of the Buffer. |
Buffer |
Buffer.appendIntLE(int i)
Appends the specified
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendLong(long l)
Appends the specified
long to the end of the Buffer. |
Buffer |
Buffer.appendLongLE(long l)
Appends the specified
long to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendMedium(int i)
Appends the specified 24bit
int to the end of the Buffer. |
Buffer |
Buffer.appendMediumLE(int i)
Appends the specified 24bit
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendShort(short s)
Appends the specified
short to the end of the Buffer.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendShortLE(short s)
Appends the specified
short to the end of the Buffer in the Little Endian Byte Order.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendString(String str)
Appends the specified
String str to the end of the Buffer with UTF-8 encoding. |
Buffer |
Buffer.appendString(String str,
String enc)
Appends the specified
String to the end of the Buffer with the encoding as specified by enc. |
Buffer |
Buffer.appendUnsignedByte(short b)
Appends the specified unsigned
byte to the end of the Buffer. |
Buffer |
Buffer.appendUnsignedInt(long i)
Appends the specified unsigned
int to the end of the Buffer. |
Buffer |
Buffer.appendUnsignedIntLE(long i)
Appends the specified unsigned
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendUnsignedShort(int s)
Appends the specified unsigned
short to the end of the Buffer.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendUnsignedShortLE(int s)
Appends the specified unsigned
short to the end of the Buffer in the Little Endian Byte Order.The buffer will expand as necessary to accommodate any bytes written. |
static Buffer |
Buffer.buffer()
Create a new, empty buffer.
|
static Buffer |
Buffer.buffer(byte[] bytes)
Create a new buffer from a byte[].
|
static Buffer |
Buffer.buffer(ByteBuf byteBuf)
Deprecated.
|
static Buffer |
Buffer.buffer(int initialSizeHint)
Create a new buffer given the initial size hint.
|
static Buffer |
Buffer.buffer(String string)
Create a new buffer from a string.
|
static Buffer |
Buffer.buffer(String string,
String enc)
Create a new buffer from a string and using the specified encoding.
|
Buffer |
Buffer.copy()
Returns a copy of the entire Buffer.
|
Buffer |
Buffer.getBuffer(int start,
int end)
Returns a copy of a sub-sequence the Buffer as a
Buffer starting at position start
and ending at position end - 1 |
Buffer |
Buffer.getBytes(byte[] dst)
Transfers the content of the Buffer into a
byte[]. |
Buffer |
Buffer.getBytes(byte[] dst,
int dstIndex)
Transfers the content of the Buffer into a
byte[] at the specific destination. |
Buffer |
Buffer.getBytes(int start,
int end,
byte[] dst)
Transfers the content of the Buffer starting at position
start and ending at position end - 1
into a byte[]. |
Buffer |
Buffer.getBytes(int start,
int end,
byte[] dst,
int dstIndex)
Transfers the content of the Buffer starting at position
start and ending at position end - 1
into a byte[] at the specific destination. |
static Buffer |
Buffer.newInstance(Buffer arg) |
Buffer |
Buffer.setBuffer(int pos,
Buffer b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b. |
Buffer |
Buffer.setBuffer(int pos,
Buffer b,
int offset,
int len)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b on the given offset and len. |
Buffer |
Buffer.setByte(int pos,
byte b)
Sets the
byte at position pos in the Buffer to the value b. |
Buffer |
Buffer.setBytes(int pos,
byte[] b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the byte[] b. |
Buffer |
Buffer.setBytes(int pos,
byte[] b,
int offset,
int len)
Sets the given number of bytes at position
pos in the Buffer to the bytes represented by the byte[] b. |
Buffer |
Buffer.setBytes(int pos,
ByteBuffer b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the ByteBuffer b. |
Buffer |
Buffer.setDouble(int pos,
double d)
Sets the
double at position pos in the Buffer to the value d. |
Buffer |
Buffer.setFloat(int pos,
float f)
Sets the
float at position pos in the Buffer to the value f. |
Buffer |
Buffer.setInt(int pos,
int i)
Sets the
int at position pos in the Buffer to the value i. |
Buffer |
Buffer.setIntLE(int pos,
int i)
Sets the
int at position pos in the Buffer to the value i in the Little Endian Byte Order. |
Buffer |
Buffer.setLong(int pos,
long l)
Sets the
long at position pos in the Buffer to the value l. |
Buffer |
Buffer.setLongLE(int pos,
long l)
Sets the
long at position pos in the Buffer to the value l in the Little Endian Byte Order. |
Buffer |
Buffer.setMedium(int pos,
int i)
Sets the 24bit
int at position pos in the Buffer to the value i. |
Buffer |
Buffer.setMediumLE(int pos,
int i)
Sets the 24bit
int at position pos in the Buffer to the value i. |
Buffer |
Buffer.setShort(int pos,
short s)
Sets the
short at position pos in the Buffer to the value s. |
Buffer |
Buffer.setShortLE(int pos,
short s)
Sets the
short at position pos in the Buffer to the value s in the Little Endian Byte Order. |
Buffer |
Buffer.setString(int pos,
String str)
Sets the bytes at position
pos in the Buffer to the value of str encoded in UTF-8. |
Buffer |
Buffer.setString(int pos,
String str,
String enc)
Sets the bytes at position
pos in the Buffer to the value of str encoded in encoding enc. |
Buffer |
Buffer.setUnsignedByte(int pos,
short b)
Sets the unsigned
byte at position pos in the Buffer to the value b. |
Buffer |
Buffer.setUnsignedInt(int pos,
long i)
Sets the unsigned
int at position pos in the Buffer to the value i. |
Buffer |
Buffer.setUnsignedIntLE(int pos,
long i)
Sets the unsigned
int at position pos in the Buffer to the value i in the Little Endian Byte Order. |
Buffer |
Buffer.setUnsignedShort(int pos,
int s)
Sets the unsigned
short at position pos in the Buffer to the value s. |
Buffer |
Buffer.setUnsignedShortLE(int pos,
int s)
Sets the unsigned
short at position pos in the Buffer to the value s in the Little Endian Byte Order. |
Buffer |
Buffer.slice()
Returns a slice of this buffer.
|
Buffer |
Buffer.slice(int start,
int end)
Returns a slice of this buffer.
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
Buffer.appendBuffer(Buffer buff)
Appends the specified
Buffer to the end of this Buffer. |
Buffer |
Buffer.appendBuffer(Buffer buff,
int offset,
int len)
Appends the specified
Buffer starting at the offset using len to the end of this Buffer. |
Buffer |
Buffer.setBuffer(int pos,
Buffer b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b. |
Buffer |
Buffer.setBuffer(int pos,
Buffer b,
int offset,
int len)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b on the given offset and len. |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
DatagramPacket.data()
Returns the data of the
DatagramPacket |
| Modifier and Type | Method and Description |
|---|---|
WriteStream<Buffer> |
DatagramSocket.sender(int port,
String host)
Returns a
WriteStream able to send to the
SocketAddress. |
| Modifier and Type | Method and Description |
|---|---|
Completable |
DatagramSocket.rxSend(Buffer packet,
int port,
String host)
Write the given
Buffer to the SocketAddress. |
Completable |
DatagramSocket.send(Buffer packet,
int port,
String host)
Write the given
Buffer to the SocketAddress. |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
FileSystem.readFileBlocking(String path)
Blocking version of
FileSystem.readFile(java.lang.String) |
| Modifier and Type | Method and Description |
|---|---|
Pipe<Buffer> |
AsyncFile.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Single<Buffer> |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
Single<Buffer> |
FileSystem.readFile(String path)
Reads the entire file as represented by the path
path as a , asynchronously. |
Single<Buffer> |
AsyncFile.rxRead(Buffer buffer,
int offset,
long position,
int length)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
Single<Buffer> |
FileSystem.rxReadFile(String path)
Reads the entire file as represented by the path
path as a , asynchronously. |
Flowable<Buffer> |
AsyncFile.toFlowable() |
Observable<Buffer> |
AsyncFile.toObservable() |
WriteStreamObserver<Buffer> |
AsyncFile.toObserver() |
WriteStreamSubscriber<Buffer> |
AsyncFile.toSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
Completable |
AsyncFile.end(Buffer data)
Same as but with an
handler called when the operation completes |
Single<Buffer> |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
Completable |
AsyncFile.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Single<Buffer> |
AsyncFile.rxRead(Buffer buffer,
int offset,
long position,
int length)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
Completable |
AsyncFile.rxWrite(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
AsyncFile.rxWrite(Buffer buffer,
long position)
Write a
Buffer to the file at position position in the file, asynchronously. |
Completable |
FileSystem.rxWriteFile(String path,
Buffer data)
Creates the file, and writes the specified
Buffer data to the file represented by the path path,
asynchronously. |
Completable |
AsyncFile.write(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
AsyncFile.write(Buffer buffer,
long position)
Write a
Buffer to the file at position position in the file, asynchronously. |
Completable |
FileSystem.writeFile(String path,
Buffer data)
Creates the file, and writes the specified
Buffer data to the file represented by the path path,
asynchronously. |
FileSystem |
FileSystem.writeFileBlocking(String path,
Buffer data)
Blocking version of
FileSystem.writeFile(java.lang.String, io.vertx.rxjava3.core.buffer.Buffer) |
| Modifier and Type | Method and Description |
|---|---|
AsyncFile |
AsyncFile.handler(Handler<Buffer> handler) |
Completable |
AsyncFile.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
AsyncFile.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
WebSocketFrame.binaryData() |
Buffer |
HttpFrame.payload() |
| Modifier and Type | Method and Description |
|---|---|
Single<Buffer> |
HttpClientResponse.body()
Same as
HttpClientResponse.body() but with an handler called when the operation completes |
Single<Buffer> |
HttpConnection.ping(Buffer data)
Send a frame to the remote endpoint.
|
Pipe<Buffer> |
HttpClientResponse.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
ServerWebSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
WebSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
HttpServerFileUpload.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
HttpServerRequest.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
ClientWebSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
WebSocketBase.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Single<Buffer> |
HttpClientResponse.rxBody()
Same as
HttpClientResponse.body() but with an handler called when the operation completes |
Single<Buffer> |
HttpConnection.rxPing(Buffer data)
Send a frame to the remote endpoint.
|
Flowable<Buffer> |
HttpClientResponse.toFlowable() |
Flowable<Buffer> |
ServerWebSocket.toFlowable() |
Flowable<Buffer> |
WebSocket.toFlowable() |
Flowable<Buffer> |
HttpServerFileUpload.toFlowable() |
Flowable<Buffer> |
HttpServerRequest.toFlowable() |
Flowable<Buffer> |
ClientWebSocket.toFlowable() |
Observable<Buffer> |
HttpClientResponse.toObservable() |
Observable<Buffer> |
ServerWebSocket.toObservable() |
Observable<Buffer> |
WebSocket.toObservable() |
Observable<Buffer> |
HttpServerFileUpload.toObservable() |
Observable<Buffer> |
HttpServerRequest.toObservable() |
Observable<Buffer> |
ClientWebSocket.toObservable() |
WriteStreamObserver<Buffer> |
HttpServerResponse.toObserver() |
WriteStreamObserver<Buffer> |
ServerWebSocket.toObserver() |
WriteStreamObserver<Buffer> |
HttpClientRequest.toObserver() |
WriteStreamObserver<Buffer> |
WebSocket.toObserver() |
WriteStreamObserver<Buffer> |
ClientWebSocket.toObserver() |
WriteStreamSubscriber<Buffer> |
HttpServerResponse.toSubscriber() |
WriteStreamSubscriber<Buffer> |
ServerWebSocket.toSubscriber() |
WriteStreamSubscriber<Buffer> |
HttpClientRequest.toSubscriber() |
WriteStreamSubscriber<Buffer> |
WebSocket.toSubscriber() |
WriteStreamSubscriber<Buffer> |
ClientWebSocket.toSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
static WebSocketFrame |
WebSocketFrame.binaryFrame(Buffer data,
boolean isFinal)
Create a binary WebSocket frame.
|
static WebSocketFrame |
WebSocketFrame.continuationFrame(Buffer data,
boolean isFinal)
Create a continuation frame
|
Completable |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse.end() but with an handler called when the operation completes |
Completable |
ServerWebSocket.end(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
HttpClientRequest.end(Buffer chunk)
Same as
HttpClientRequest.end(java.lang.String) but with an handler called when the operation completes |
Completable |
WebSocket.end(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
ClientWebSocket.end(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
WebSocketBase.end(Buffer data)
Same as but with an
handler called when the operation completes |
HttpConnection |
HttpConnection.goAway(long errorCode,
int lastStreamId,
Buffer debugData)
Send a go away frame to the remote endpoint of the connection.
|
Single<Buffer> |
HttpConnection.ping(Buffer data)
Send a frame to the remote endpoint.
|
static WebSocketFrame |
WebSocketFrame.pingFrame(Buffer data)
Create a ping WebSocket frame.
|
static WebSocketFrame |
WebSocketFrame.pongFrame(Buffer data)
Create a pong WebSocket frame.
|
Completable |
HttpServerResponse.rxEnd(Buffer chunk)
Same as
HttpServerResponse.end() but with an handler called when the operation completes |
Completable |
ServerWebSocket.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
HttpClientRequest.rxEnd(Buffer chunk)
Same as
HttpClientRequest.end(java.lang.String) but with an handler called when the operation completes |
Completable |
WebSocket.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
ClientWebSocket.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
WebSocketBase.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Single<Buffer> |
HttpConnection.rxPing(Buffer data)
Send a frame to the remote endpoint.
|
Completable |
HttpServerResponse.rxSend(Buffer body)
Send the request with a buffer
body. |
Single<HttpClientResponse> |
HttpClientRequest.rxSend(Buffer body)
Send the request with a buffer
body. |
Completable |
HttpServerResponse.rxWrite(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
ServerWebSocket.rxWrite(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
HttpClientRequest.rxWrite(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
WebSocket.rxWrite(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
ClientWebSocket.rxWrite(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
WebSocketBase.rxWrite(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
ServerWebSocket.rxWriteBinaryMessage(Buffer data) |
Completable |
WebSocket.rxWriteBinaryMessage(Buffer data) |
Completable |
ClientWebSocket.rxWriteBinaryMessage(Buffer data) |
Completable |
WebSocketBase.rxWriteBinaryMessage(Buffer data)
Same as
WebSocketBase.writeBinaryMessage(io.vertx.rxjava3.core.buffer.Buffer) but with an handler called when the operation completes |
Completable |
ServerWebSocket.rxWriteFinalBinaryFrame(Buffer data) |
Completable |
WebSocket.rxWriteFinalBinaryFrame(Buffer data) |
Completable |
ClientWebSocket.rxWriteFinalBinaryFrame(Buffer data) |
Completable |
WebSocketBase.rxWriteFinalBinaryFrame(Buffer data)
Same as
WebSocketBase.writeFinalBinaryFrame(io.vertx.rxjava3.core.buffer.Buffer) but with an handler called when the operation completes |
Completable |
ServerWebSocket.rxWritePing(Buffer data) |
Completable |
WebSocket.rxWritePing(Buffer data) |
Completable |
ClientWebSocket.rxWritePing(Buffer data) |
Completable |
WebSocketBase.rxWritePing(Buffer data)
Writes a ping frame to the connection.
|
Completable |
ServerWebSocket.rxWritePong(Buffer data) |
Completable |
WebSocket.rxWritePong(Buffer data) |
Completable |
ClientWebSocket.rxWritePong(Buffer data) |
Completable |
WebSocketBase.rxWritePong(Buffer data)
Writes a pong frame to the connection.
|
Completable |
HttpServerResponse.send(Buffer body)
Send the request with a buffer
body. |
Single<HttpClientResponse> |
HttpClientRequest.send(Buffer body)
Send the request with a buffer
body. |
Completable |
HttpServerResponse.write(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
ServerWebSocket.write(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
HttpClientRequest.write(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
WebSocket.write(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
ClientWebSocket.write(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
WebSocketBase.write(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
ServerWebSocket.writeBinaryMessage(Buffer data) |
Completable |
WebSocket.writeBinaryMessage(Buffer data) |
Completable |
ClientWebSocket.writeBinaryMessage(Buffer data) |
Completable |
WebSocketBase.writeBinaryMessage(Buffer data)
Same as
WebSocketBase.writeBinaryMessage(io.vertx.rxjava3.core.buffer.Buffer) but with an handler called when the operation completes |
HttpServerResponse |
HttpServerResponse.writeCustomFrame(int type,
int flags,
Buffer payload)
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.
|
HttpClientRequest |
HttpClientRequest.writeCustomFrame(int type,
int flags,
Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.
|
Completable |
ServerWebSocket.writeFinalBinaryFrame(Buffer data) |
Completable |
WebSocket.writeFinalBinaryFrame(Buffer data) |
Completable |
ClientWebSocket.writeFinalBinaryFrame(Buffer data) |
Completable |
WebSocketBase.writeFinalBinaryFrame(Buffer data)
Same as
WebSocketBase.writeFinalBinaryFrame(io.vertx.rxjava3.core.buffer.Buffer) but with an handler called when the operation completes |
Completable |
ServerWebSocket.writePing(Buffer data) |
Completable |
WebSocket.writePing(Buffer data) |
Completable |
ClientWebSocket.writePing(Buffer data) |
Completable |
WebSocketBase.writePing(Buffer data)
Writes a ping frame to the connection.
|
Completable |
ServerWebSocket.writePong(Buffer data) |
Completable |
WebSocket.writePong(Buffer data) |
Completable |
ClientWebSocket.writePong(Buffer data) |
Completable |
WebSocketBase.writePong(Buffer data)
Writes a pong frame to the connection.
|
| Modifier and Type | Method and Description |
|---|---|
WebSocketBase |
ServerWebSocket.binaryMessageHandler(Handler<Buffer> handler)
Set a binary message handler on the connection.
|
WebSocketBase |
WebSocket.binaryMessageHandler(Handler<Buffer> handler)
Set a binary message handler on the connection.
|
ClientWebSocket |
ClientWebSocket.binaryMessageHandler(Handler<Buffer> handler) |
WebSocketBase |
WebSocketBase.binaryMessageHandler(Handler<Buffer> handler)
Set a binary message handler on the connection.
|
HttpServerRequest |
HttpServerRequest.body(Handler<AsyncResult<Buffer>> handler)
Same as
HttpServerRequest.body(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava3.core.buffer.Buffer>>) but with an handler called when the operation completes |
HttpClientResponse |
HttpClientResponse.bodyHandler(Handler<Buffer> bodyHandler)
Convenience method for receiving the entire request body in one piece.
|
HttpServerRequest |
HttpServerRequest.bodyHandler(Handler<Buffer> bodyHandler)
Convenience method for receiving the entire request body in one piece.
|
HttpClientResponse |
HttpClientResponse.handler(Handler<Buffer> handler) |
ServerWebSocket |
ServerWebSocket.handler(Handler<Buffer> handler) |
WebSocket |
WebSocket.handler(Handler<Buffer> handler) |
HttpServerFileUpload |
HttpServerFileUpload.handler(Handler<Buffer> handler) |
HttpServerRequest |
HttpServerRequest.handler(Handler<Buffer> handler) |
ClientWebSocket |
ClientWebSocket.handler(Handler<Buffer> handler) |
WebSocketBase |
WebSocketBase.handler(Handler<Buffer> handler) |
HttpConnection |
HttpConnection.pingHandler(Handler<Buffer> handler)
Set an handler notified when a frame is received from the remote endpoint.
|
Completable |
HttpClientResponse.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
ServerWebSocket.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
WebSocket.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
HttpServerFileUpload.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
HttpServerRequest.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
ClientWebSocket.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
WebSocketBase.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
WebSocketBase |
ServerWebSocket.pongHandler(Handler<Buffer> handler)
Set a pong frame handler on the connection.
|
WebSocketBase |
WebSocket.pongHandler(Handler<Buffer> handler)
Set a pong frame handler on the connection.
|
ClientWebSocket |
ClientWebSocket.pongHandler(Handler<Buffer> handler) |
WebSocketBase |
WebSocketBase.pongHandler(Handler<Buffer> handler)
Set a pong frame handler on the connection.
|
Completable |
HttpClientResponse.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
ServerWebSocket.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
WebSocket.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
HttpServerFileUpload.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
HttpServerRequest.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
ClientWebSocket.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
WebSocketBase.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
HttpServerResponse.rxSend(Flowable<Buffer> body)
Send the request with a stream
body. |
Single<HttpClientResponse> |
HttpClientRequest.rxSend(Flowable<Buffer> body)
Send the request with a stream
body. |
Completable |
HttpServerResponse.send(Flowable<Buffer> body)
Send the request with a stream
body. |
Single<HttpClientResponse> |
HttpClientRequest.send(Flowable<Buffer> body)
Send the request with a stream
body. |
| Modifier and Type | Method and Description |
|---|---|
Pipe<Buffer> |
NetSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Flowable<Buffer> |
NetSocket.toFlowable() |
Observable<Buffer> |
NetSocket.toObservable() |
WriteStreamObserver<Buffer> |
NetSocket.toObserver() |
WriteStreamSubscriber<Buffer> |
NetSocket.toSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
Completable |
NetSocket.end(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
NetSocket.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
NetSocket.rxWrite(Buffer message)
Like
WriteStream.write(T) but with an handler called when the message has been written
or failed to be written. |
Completable |
NetSocket.write(Buffer message)
Like
WriteStream.write(T) but with an handler called when the message has been written
or failed to be written. |
| Modifier and Type | Method and Description |
|---|---|
NetSocket |
NetSocket.handler(Handler<Buffer> handler) |
Completable |
NetSocket.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
NetSocket.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
JsonEvent.binaryValue()
Return the binary value.
|
| Modifier and Type | Method and Description |
|---|---|
Pipe<Buffer> |
RecordParser.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Flowable<Buffer> |
RecordParser.toFlowable() |
Observable<Buffer> |
RecordParser.toObservable() |
| Modifier and Type | Method and Description |
|---|---|
void |
RecordParser.delimitedMode(Buffer delim)
Flip the parser into delimited mode, and where the delimiter can be represented
by the delimiter
delim. |
void |
RecordParser.handle(Buffer buffer)
This method is called to provide the parser with data.
|
void |
JsonParser.handle(Buffer event)
Something has happened, so handle it.
|
static RecordParser |
RecordParser.newDelimited(Buffer delim)
Create a new
RecordParser instance, initially in delimited mode, and where the delimiter can be represented
by the Buffer delim. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Flowable<Buffer> stream)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava3.core.buffer.Buffer>) but wraps the stream. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Handler<Buffer> output)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava3.core.buffer.Buffer>) but set the output that will receive whole records
which have been parsed. |
JsonParser |
JsonParser.write(Buffer buffer)
Handle a
Buffer, pretty much like calling Handler. |
| Modifier and Type | Method and Description |
|---|---|
RecordParser |
RecordParser.handler(Handler<Buffer> handler) |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Flowable<Buffer> stream)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava3.core.buffer.Buffer>) but wraps the stream. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Handler<Buffer> output)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava3.core.buffer.Buffer>) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newDelimited(String delim,
Flowable<Buffer> stream)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava3.core.buffer.Buffer>) but wraps the stream. |
static RecordParser |
RecordParser.newDelimited(String delim,
Handler<Buffer> output)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava3.core.buffer.Buffer>) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newFixed(int size,
Flowable<Buffer> stream)
Like
RecordParser.newFixed(int) but wraps the stream. |
static RecordParser |
RecordParser.newFixed(int size,
Handler<Buffer> output)
Like
RecordParser.newFixed(int) but set the output that will receive whole records
which have been parsed. |
static JsonParser |
JsonParser.newParser(Flowable<Buffer> stream)
Create a new
JsonParser instance. |
Completable |
RecordParser.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
RecordParser.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
void |
RecordParser.setOutput(Handler<Buffer> output) |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
MailAttachment.getData()
get the data
|
| Modifier and Type | Method and Description |
|---|---|
ReadStream<Buffer> |
MailAttachment.getStream()
Gets the data stream.
|
| Modifier and Type | Method and Description |
|---|---|
MailAttachment |
MailAttachment.setData(Buffer data)
set the data
|
| Modifier and Type | Method and Description |
|---|---|
MailAttachment |
MailAttachment.setStream(Flowable<Buffer> stream)
Sets the data stream.
|
| Modifier and Type | Method and Description |
|---|---|
ReadStream<Buffer> |
MongoGridFsClient.readByFileName(String fileName)
Read file by name to ReadStream
|
ReadStream<Buffer> |
MongoGridFsClient.readByFileNameWithOptions(String fileName,
GridFsDownloadOptions options)
Read file by name to ReadStream with options
|
ReadStream<Buffer> |
MongoGridFsClient.readById(String id)
Read file by id to ReadStream
|
| Modifier and Type | Method and Description |
|---|---|
Single<Frame> |
StompClientConnection.rxSend(Map<String,String> headers,
Buffer body)
Sends a
SEND frame to the server. |
Single<Frame> |
StompClientConnection.rxSend(String destination,
Buffer body)
Sends a
SEND frame to the server to the given destination. |
Single<Frame> |
StompClientConnection.rxSend(String destination,
Map<String,String> headers,
Buffer body)
Sends a
SEND frame to the server to the given destination. |
Single<Frame> |
StompClientConnection.send(Map<String,String> headers,
Buffer body)
Sends a
SEND frame to the server. |
Single<Frame> |
StompClientConnection.send(String destination,
Buffer body)
Sends a
SEND frame to the server to the given destination. |
Single<Frame> |
StompClientConnection.send(String destination,
Map<String,String> headers,
Buffer body)
Sends a
SEND frame to the server to the given destination. |
StompServerConnection |
StompServerConnection.write(Buffer buffer)
Writes the given buffer to the socket.
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
RequestBody.buffer() |
Buffer |
RoutingContext.getBody()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
Completable |
RoutingContext.end(Buffer buffer)
|
Completable |
RoutingContext.rxEnd(Buffer buffer)
|
void |
RoutingContext.setBody(Buffer body)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
HttpResponse.bodyAsBuffer() |
| Modifier and Type | Method and Description |
|---|---|
HttpRequest<Buffer> |
WebClient.delete(int port,
String host,
String requestURI)
Create an HTTP DELETE request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.delete(int port,
String host,
UriTemplate requestURI)
Create an HTTP DELETE request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.delete(String requestURI)
Create an HTTP DELETE request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.delete(String host,
String requestURI)
Create an HTTP DELETE request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.delete(String host,
UriTemplate requestURI)
Create an HTTP DELETE request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.delete(UriTemplate requestURI)
Create an HTTP DELETE request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.deleteAbs(String absoluteURI)
Create an HTTP DELETE request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.deleteAbs(UriTemplate absoluteURI)
Create an HTTP DELETE request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.get(int port,
String host,
String requestURI)
Create an HTTP GET request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.get(int port,
String host,
UriTemplate requestURI)
Create an HTTP GET request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.get(String requestURI)
Create an HTTP GET request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.get(String host,
String requestURI)
Create an HTTP GET request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.get(String host,
UriTemplate requestURI)
Create an HTTP GET request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.get(UriTemplate requestURI)
Create an HTTP GET request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.getAbs(String absoluteURI)
Create an HTTP GET request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.getAbs(UriTemplate absoluteURI)
Create an HTTP GET request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.head(int port,
String host,
String requestURI)
Create an HTTP HEAD request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.head(int port,
String host,
UriTemplate requestURI)
Create an HTTP HEAD request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.head(String requestURI)
Create an HTTP HEAD request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.head(String host,
String requestURI)
Create an HTTP HEAD request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.head(String host,
UriTemplate requestURI)
Create an HTTP HEAD request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.head(UriTemplate requestURI)
Create an HTTP HEAD request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.headAbs(String absoluteURI)
Create an HTTP HEAD request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.headAbs(UriTemplate absoluteURI)
Create an HTTP HEAD request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.patch(int port,
String host,
String requestURI)
Create an HTTP PATCH request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.patch(int port,
String host,
UriTemplate requestURI)
Create an HTTP PATCH request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.patch(String requestURI)
Create an HTTP PATCH request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.patch(String host,
String requestURI)
Create an HTTP PATCH request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.patch(String host,
UriTemplate requestURI)
Create an HTTP PATCH request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.patch(UriTemplate requestURI)
Create an HTTP PATCH request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.patchAbs(String absoluteURI)
Create an HTTP PATCH request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.patchAbs(UriTemplate absoluteURI)
Create an HTTP PATCH request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.post(int port,
String host,
String requestURI)
Create an HTTP POST request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.post(int port,
String host,
UriTemplate requestURI)
Create an HTTP POST request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.post(String requestURI)
Create an HTTP POST request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.post(String host,
String requestURI)
Create an HTTP POST request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.post(String host,
UriTemplate requestURI)
Create an HTTP POST request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.post(UriTemplate requestURI)
Create an HTTP POST request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.postAbs(String absoluteURI)
Create an HTTP POST request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.postAbs(UriTemplate absoluteURI)
Create an HTTP POST request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.put(int port,
String host,
String requestURI)
Create an HTTP PUT request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.put(int port,
String host,
UriTemplate requestURI)
Create an HTTP PUT request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.put(String requestURI)
Create an HTTP PUT request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.put(String host,
String requestURI)
Create an HTTP PUT request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.put(String host,
UriTemplate requestURI)
Create an HTTP PUT request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.put(UriTemplate requestURI)
Create an HTTP PUT request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.putAbs(String absoluteURI)
Create an HTTP PUT request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.putAbs(UriTemplate absoluteURI)
Create an HTTP PUT request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
int port,
String host,
String requestURI)
Create an HTTP request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
int port,
String host,
UriTemplate requestURI)
Create an HTTP request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
RequestOptions options)
Create an HTTP request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
int port,
String host,
String requestURI)
Like
WebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String) using the serverAddress parameter to connect to the
server instead of the port and host parameters. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
int port,
String host,
UriTemplate requestURI)
Like
WebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String) using the serverAddress parameter to connect to the
server instead of the port and host parameters. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
RequestOptions options)
Like
WebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String) using the serverAddress parameter to connect to the
server instead of the options parameter. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
String requestURI)
Like
WebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String) using the serverAddress parameter to connect to the
server instead of the default port and default host. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
String host,
String requestURI)
Like
WebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String) using the serverAddress parameter to connect to the
server instead of the default port and host parameter. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
String host,
UriTemplate requestURI)
Like
WebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String) using the serverAddress parameter to connect to the
server instead of the default port and host parameter. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
UriTemplate requestURI)
Like
WebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String) using the serverAddress parameter to connect to the
server instead of the default port and default host. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
String requestURI)
Create an HTTP request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
String host,
String requestURI)
Create an HTTP request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
String host,
UriTemplate requestURI)
Create an HTTP request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
UriTemplate requestURI)
Create an HTTP request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.requestAbs(HttpMethod method,
SocketAddress serverAddress,
String absoluteURI)
Like
WebClient.requestAbs(io.vertx.core.http.HttpMethod, java.lang.String) using the serverAddress parameter to connect to the
server instead of the absoluteURI parameter. |
HttpRequest<Buffer> |
WebClient.requestAbs(HttpMethod method,
SocketAddress serverAddress,
UriTemplate absoluteURI)
Like
WebClient.requestAbs(io.vertx.core.http.HttpMethod, java.lang.String) using the serverAddress parameter to connect to the
server instead of the absoluteURI parameter. |
HttpRequest<Buffer> |
WebClient.requestAbs(HttpMethod method,
String absoluteURI)
Create an HTTP request to send to the server using an absolute URI
|
HttpRequest<Buffer> |
WebClient.requestAbs(HttpMethod method,
UriTemplate absoluteURI)
Create an HTTP request to send to the server using an absolute URI
|
| Modifier and Type | Method and Description |
|---|---|
HttpRequest<T> |
HttpRequest.basicAuthentication(Buffer id,
Buffer password)
Configure the request to perform basic access authentication.
|
Single<HttpResponse<T>> |
HttpRequest.rxSendBuffer(Buffer body)
Like
HttpRequest.send() but with an HTTP request body buffer. |
Single<HttpResponse<T>> |
HttpRequest.sendBuffer(Buffer body)
Like
HttpRequest.send() but with an HTTP request body buffer. |
| Modifier and Type | Method and Description |
|---|---|
Single<HttpResponse<T>> |
HttpRequest.rxSendStream(Flowable<Buffer> body)
Like
HttpRequest.send() but with an HTTP request body stream. |
Single<HttpResponse<T>> |
HttpRequest.sendStream(Flowable<Buffer> body)
Like
HttpRequest.send() but with an HTTP request body stream. |
| Modifier and Type | Method and Description |
|---|---|
HttpResponse<Buffer> |
ResponsePredicateResult.response()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static BodyCodec<Buffer> |
BodyCodec.buffer() |
| Modifier and Type | Method and Description |
|---|---|
static <T> BodyCodec<T> |
BodyCodec.create(java.util.function.Function<Buffer,T> decode)
Create a codec that buffers the entire body and then apply the
decode function and returns the result. |
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 | Method and Description |
|---|---|
Single<Buffer> |
TemplateEngine.render(JsonObject context,
String templateFileName)
Render the template.
|
Single<Buffer> |
TemplateEngine.render(Map<String,Object> context,
String templateFileName)
Render the template.
|
Single<Buffer> |
TemplateEngine.rxRender(JsonObject context,
String templateFileName)
Render the template.
|
Single<Buffer> |
TemplateEngine.rxRender(Map<String,Object> context,
String templateFileName)
Render the template.
|
| Modifier and Type | Method and Description |
|---|---|
Pipe<Buffer> |
SockJSSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Flowable<Buffer> |
SockJSSocket.toFlowable() |
Observable<Buffer> |
SockJSSocket.toObservable() |
WriteStreamObserver<Buffer> |
SockJSSocket.toObserver() |
WriteStreamSubscriber<Buffer> |
SockJSSocket.toSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
Completable |
SockJSSocket.end(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
SockJSSocket.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Completable |
SockJSSocket.rxWrite(Buffer data) |
Completable |
SockJSSocket.write(Buffer data) |
| Modifier and Type | Method and Description |
|---|---|
SockJSSocket |
SockJSSocket.handler(Handler<Buffer> handler) |
Completable |
SockJSSocket.pipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Completable |
SockJSSocket.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
FormDataPart.content() |
| Modifier and Type | Method and Description |
|---|---|
MultipartForm |
MultipartForm.binaryFileUpload(String name,
String filename,
Buffer content,
String mediaType)
Add a binary file upload form data part.
|
MultipartForm |
MultipartForm.textFileUpload(String name,
String filename,
Buffer content,
String mediaType)
Add a text file upload form data part.
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
RequestParameter.getBuffer() |
| Modifier and Type | Method and Description |
|---|---|
Single<GrpcClientRequest<Buffer,Buffer>> |
GrpcClient.request(SocketAddress server)
Connect to the remote
server and create a request for any hosted gRPC service. |
Single<GrpcClientRequest<Buffer,Buffer>> |
GrpcClient.request(SocketAddress server)
Connect to the remote
server and create a request for any hosted gRPC service. |
Single<GrpcClientRequest<Buffer,Buffer>> |
GrpcClient.rxRequest(SocketAddress server)
Connect to the remote
server and create a request for any hosted gRPC service. |
Single<GrpcClientRequest<Buffer,Buffer>> |
GrpcClient.rxRequest(SocketAddress server)
Connect to the remote
server and create a request for any hosted gRPC service. |
| Modifier and Type | Field and Description |
|---|---|
static GrpcMessageDecoder<Buffer> |
GrpcMessageDecoder.GZIP |
static GrpcMessageEncoder<Buffer> |
GrpcMessageEncoder.GZIP |
static GrpcMessageDecoder<Buffer> |
GrpcMessageDecoder.IDENTITY |
static GrpcMessageEncoder<Buffer> |
GrpcMessageEncoder.IDENTITY |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
GrpcMessage.payload() |
| Modifier and Type | Method and Description |
|---|---|
static GrpcMessage |
GrpcMessage.message(String encoding,
Buffer payload) |
| Modifier and Type | Method and Description |
|---|---|
GrpcServer |
GrpcServer.callHandler(Handler<GrpcServerRequest<Buffer,Buffer>> handler)
Set a call handler that handles any call made to the server.
|
GrpcServer |
GrpcServer.callHandler(Handler<GrpcServerRequest<Buffer,Buffer>> handler)
Set a call handler that handles any call made to the server.
|
| Modifier and Type | Method and Description |
|---|---|
ReadStream<Buffer> |
Body.stream()
Get stream of the
Body. |
| Modifier and Type | Method and Description |
|---|---|
static Body |
Body.body(Buffer buffer)
Create a new
Body instance. |
| Modifier and Type | Method and Description |
|---|---|
static Body |
Body.body(Flowable<Buffer> stream)
Create a new
Body instance. |
static Body |
Body.body(Flowable<Buffer> stream,
long len)
Create a new
Body instance. |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
KafkaHeader.value() |
| Modifier and Type | Method and Description |
|---|---|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(String key,
Buffer value)
Like
KafkaProducerRecord.addHeader(java.lang.String, java.lang.String) but with a key/value pair |
static KafkaHeader |
KafkaHeader.header(String key,
Buffer value) |
| Modifier and Type | Method and Description |
|---|---|
Single<Integer> |
MqttClient.publish(String topic,
Buffer payload,
MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
Single<Integer> |
MqttEndpoint.publish(String topic,
Buffer payload,
MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
Single<Integer> |
MqttEndpoint.publish(String topic,
Buffer payload,
MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
Single<Integer> |
MqttEndpoint.publish(String topic,
Buffer payload,
MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId,
MqttProperties properties)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
Single<Integer> |
MqttClient.rxPublish(String topic,
Buffer payload,
MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
Single<Integer> |
MqttEndpoint.rxPublish(String topic,
Buffer payload,
MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
Single<Integer> |
MqttEndpoint.rxPublish(String topic,
Buffer payload,
MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
Single<Integer> |
MqttEndpoint.rxPublish(String topic,
Buffer payload,
MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId,
MqttProperties properties)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
MqttPublishMessage.payload() |
| Modifier and Type | Method and Description |
|---|---|
static ValidatableResponse |
ValidatableResponse.create(int statusCode,
Buffer body,
String contentType)
Creates a new
ValidatableResponse object based on the passed parameters. |
static ValidatableResponse |
ValidatableResponse.create(int statusCode,
Map<String,String> headers,
Buffer body,
String contentType)
Creates a new
ValidatableResponse object based on the passed parameters. |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
RabbitMQMessage.body() |
| Modifier and Type | Method and Description |
|---|---|
Completable |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
Completable |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
Buffer body)
Publish a message.
|
Completable |
RabbitMQClient.basicPublishWithDeliveryTag(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
Handler<Long> deliveryTagHandler)
Publish a message.
|
Completable |
RabbitMQPublisher.publish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
Single<Long> |
RabbitMQPublisher.publishConfirm(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message and complete when publish confirm has returned.
|
Completable |
RabbitMQClient.rxBasicPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
Completable |
RabbitMQClient.rxBasicPublish(String exchange,
String routingKey,
Buffer body)
Publish a message.
|
Completable |
RabbitMQClient.rxBasicPublishWithDeliveryTag(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
Handler<Long> deliveryTagHandler)
Publish a message.
|
Completable |
RabbitMQPublisher.rxPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
Single<Long> |
RabbitMQPublisher.rxPublishConfirm(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message and complete when publish confirm has returned.
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
Response.toBuffer()
Get this response as Buffer.
|
| Modifier and Type | Method and Description |
|---|---|
Request |
Request.arg(Buffer arg)
Adds a String key argument
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
Tuple.getBuffer(int pos)
Get a buffer value at
pos. |
Buffer |
Row.getBuffer(String column)
Get a buffer value for the given
column. |
| Modifier and Type | Method and Description |
|---|---|
Tuple |
Tuple.addBuffer(Buffer value)
Add a buffer value at the end of the tuple.
|
Copyright © 2024 Eclipse. All rights reserved.