| 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> Observable.Operator<T,Buffer> |
RxHelper.unmarshaller(Class<T> mappedType)
Returns a json unmarshaller for the specified java type as a
Observable.Operator instance.
The marshaller can be used with the Observable.lift(rx.Observable.Operator) method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object. |
| 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(io.netty.buffer.ByteBuf byteBuf)
Create a new buffer from a Netty
ByteBuf. |
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 |
|---|---|
Single<DatagramSocket> |
DatagramSocket.rxSend(Buffer packet,
int port,
String host)
Write the given
Buffer to the SocketAddress. |
DatagramSocket |
DatagramSocket.send(Buffer packet,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
Buffer to the SocketAddress. |
Observable<DatagramSocket> |
DatagramSocket.sendObservable(Buffer packet,
int port,
String host)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
FileSystem.readFileBlocking(String path)
|
| 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 .
|
Observable<Buffer> |
FileSystem.readFileObservable(String path)
Deprecated.
use
FileSystem.rxReadFile(java.lang.String) instead |
Observable<Buffer> |
AsyncFile.readObservable(Buffer buffer,
int offset,
long position,
int length)
Deprecated.
|
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. |
Observable<Buffer> |
AsyncFile.toObservable() |
io.vertx.rx.java.WriteStreamSubscriber<Buffer> |
AsyncFile.toSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
void |
AsyncFile.end(Buffer data)
Same as
AsyncFile.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
void |
AsyncFile.end(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as but with an
handler called when the operation completes |
Observable<Void> |
AsyncFile.endObservable(Buffer data)
Deprecated.
|
AsyncFile |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length,
Handler<AsyncResult<Buffer>> handler)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
Observable<Buffer> |
AsyncFile.readObservable(Buffer buffer,
int offset,
long position,
int length)
Deprecated.
|
Single<Void> |
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. |
Single<Void> |
AsyncFile.rxWrite(Buffer data)
Same as
AsyncFile.write(io.vertx.rxjava.core.buffer.Buffer) but with an handler called when the operation completes |
Single<Void> |
AsyncFile.rxWrite(Buffer buffer,
long position)
Write a
Buffer to the file at position position in the file, asynchronously. |
Single<Void> |
FileSystem.rxWriteFile(String path,
Buffer data)
Creates the file, and writes the specified
Buffer data to the file represented by the path path,
asynchronously. |
AsyncFile |
AsyncFile.write(Buffer data) |
AsyncFile |
AsyncFile.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
AsyncFile.write(io.vertx.rxjava.core.buffer.Buffer) but with an handler called when the operation completes |
AsyncFile |
AsyncFile.write(Buffer buffer,
long position,
Handler<AsyncResult<Void>> handler)
Write a
Buffer to the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.writeFile(String path,
Buffer data,
Handler<AsyncResult<Void>> handler)
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)
|
Observable<Void> |
FileSystem.writeFileObservable(String path,
Buffer data)
Deprecated.
|
Observable<Void> |
AsyncFile.writeObservable(Buffer data)
Deprecated.
|
Observable<Void> |
AsyncFile.writeObservable(Buffer buffer,
long position)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
AsyncFile |
AsyncFile.handler(Handler<Buffer> handler) |
void |
AsyncFile.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
AsyncFile.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
Observable<Void> |
AsyncFile.pipeToObservable(WriteStream<Buffer> dst)
Deprecated.
|
AsyncFile |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length,
Handler<AsyncResult<Buffer>> handler)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.readFile(String path,
Handler<AsyncResult<Buffer>> handler)
Reads the entire file as represented by the path
path as a , asynchronously. |
Single<Void> |
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 |
|---|---|
Observable<Buffer> |
HttpConnection.pingObservable(Buffer data)
Deprecated.
|
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> |
WebSocketBase.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Single<Buffer> |
HttpConnection.rxPing(Buffer data)
Send a frame to the remote endpoint.
|
Observable<Buffer> |
HttpClientResponse.toObservable() |
Observable<Buffer> |
ServerWebSocket.toObservable() |
Observable<Buffer> |
WebSocket.toObservable() |
Observable<Buffer> |
HttpServerFileUpload.toObservable() |
Observable<Buffer> |
HttpServerRequest.toObservable() |
io.vertx.rx.java.WriteStreamSubscriber<Buffer> |
HttpServerResponse.toSubscriber() |
io.vertx.rx.java.WriteStreamSubscriber<Buffer> |
ServerWebSocket.toSubscriber() |
io.vertx.rx.java.WriteStreamSubscriber<Buffer> |
HttpClientRequest.toSubscriber() |
io.vertx.rx.java.WriteStreamSubscriber<Buffer> |
WebSocket.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
|
void |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse.end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but writes some data to the response body before ending. |
void |
ServerWebSocket.end(Buffer data)
Same as
WebSocketBase.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
void |
HttpClientRequest.end(Buffer chunk)
Same as
HttpClientRequest.end(java.lang.String) but writes some data to the request body before ending. |
void |
WebSocket.end(Buffer data)
Same as
WebSocketBase.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
void |
WebSocketBase.end(Buffer data)
Same as
WebSocketBase.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
void |
HttpServerResponse.end(Buffer chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but with an handler called when the operation completes |
void |
ServerWebSocket.end(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as but with an
handler called when the operation completes |
void |
HttpClientRequest.end(Buffer chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.end(java.lang.String) but with an handler called when the operation completes |
void |
WebSocket.end(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as but with an
handler called when the operation completes |
void |
WebSocketBase.end(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as but with an
handler called when the operation completes |
Observable<Void> |
HttpServerResponse.endObservable(Buffer chunk)
Deprecated.
use
HttpServerResponse.rxEnd() instead |
Observable<Void> |
ServerWebSocket.endObservable(Buffer data)
Deprecated.
|
Observable<Void> |
HttpClientRequest.endObservable(Buffer chunk)
Deprecated.
use
HttpClientRequest.rxEnd(java.lang.String) instead |
Observable<Void> |
WebSocket.endObservable(Buffer data)
Deprecated.
|
HttpConnection |
HttpConnection.goAway(long errorCode,
int lastStreamId,
Buffer debugData)
Send a go away frame to the remote endpoint of the connection.
|
HttpConnection |
HttpConnection.ping(Buffer data,
Handler<AsyncResult<Buffer>> pongHandler)
Send a frame to the remote endpoint.
|
static WebSocketFrame |
WebSocketFrame.pingFrame(Buffer data)
Create a ping WebSocket frame.
|
Observable<Buffer> |
HttpConnection.pingObservable(Buffer data)
Deprecated.
|
static WebSocketFrame |
WebSocketFrame.pongFrame(Buffer data)
Create a pong WebSocket frame.
|
Single<Void> |
HttpServerResponse.rxEnd(Buffer chunk)
Same as
HttpServerResponse.end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but with an handler called when the operation completes |
Single<Void> |
ServerWebSocket.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Single<Void> |
HttpClientRequest.rxEnd(Buffer chunk)
Same as
HttpClientRequest.end(java.lang.String) but with an handler called when the operation completes |
Single<Void> |
WebSocket.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.
|
Single<Void> |
HttpServerResponse.rxWrite(Buffer data)
Same as
HttpServerResponse.write(io.vertx.rxjava.core.buffer.Buffer) but with an handler called when the operation completes |
Single<Void> |
ServerWebSocket.rxWrite(Buffer data) |
Single<Void> |
HttpClientRequest.rxWrite(Buffer data)
Same as
HttpClientRequest.write(io.vertx.rxjava.core.buffer.Buffer) but with an handler called when the operation completes |
Single<Void> |
WebSocket.rxWrite(Buffer data) |
Single<Void> |
ServerWebSocket.rxWriteBinaryMessage(Buffer data) |
Single<Void> |
WebSocket.rxWriteBinaryMessage(Buffer data) |
Single<Void> |
ServerWebSocket.rxWriteFinalBinaryFrame(Buffer data) |
Single<Void> |
WebSocket.rxWriteFinalBinaryFrame(Buffer data) |
HttpServerResponse |
HttpServerResponse.write(Buffer data) |
ServerWebSocket |
ServerWebSocket.write(Buffer data) |
HttpClientRequest |
HttpClientRequest.write(Buffer data) |
WebSocket |
WebSocket.write(Buffer data) |
WebSocketBase |
WebSocketBase.write(Buffer data) |
HttpServerResponse |
HttpServerResponse.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.write(io.vertx.rxjava.core.buffer.Buffer) but with an handler called when the operation completes |
ServerWebSocket |
ServerWebSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
HttpClientRequest |
HttpClientRequest.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.write(io.vertx.rxjava.core.buffer.Buffer) but with an handler called when the operation completes |
WebSocket |
WebSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
ServerWebSocket |
ServerWebSocket.writeBinaryMessage(Buffer data) |
WebSocket |
WebSocket.writeBinaryMessage(Buffer data) |
WebSocketBase |
WebSocketBase.writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.
|
ServerWebSocket |
ServerWebSocket.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeBinaryMessage(io.vertx.rxjava.core.buffer.Buffer) but with an handler called when the operation completes |
Observable<Void> |
ServerWebSocket.writeBinaryMessageObservable(Buffer data)
Deprecated.
|
Observable<Void> |
WebSocket.writeBinaryMessageObservable(Buffer data)
Deprecated.
|
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.
|
ServerWebSocket |
ServerWebSocket.writeFinalBinaryFrame(Buffer data) |
WebSocket |
WebSocket.writeFinalBinaryFrame(Buffer data) |
WebSocketBase |
WebSocketBase.writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connection
|
ServerWebSocket |
ServerWebSocket.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeFinalBinaryFrame(io.vertx.rxjava.core.buffer.Buffer) but with an handler called when the operation completes |
Observable<Void> |
ServerWebSocket.writeFinalBinaryFrameObservable(Buffer data)
Deprecated.
|
Observable<Void> |
WebSocket.writeFinalBinaryFrameObservable(Buffer data)
Deprecated.
|
Observable<Void> |
HttpServerResponse.writeObservable(Buffer data)
Deprecated.
|
Observable<Void> |
ServerWebSocket.writeObservable(Buffer data)
Deprecated.
|
Observable<Void> |
HttpClientRequest.writeObservable(Buffer data)
Deprecated.
|
Observable<Void> |
WebSocket.writeObservable(Buffer data)
Deprecated.
|
WebSocketBase |
ServerWebSocket.writePing(Buffer data)
Writes a ping frame to the connection.
|
WebSocketBase |
WebSocket.writePing(Buffer data)
Writes a ping frame to the connection.
|
WebSocketBase |
WebSocketBase.writePing(Buffer data)
Writes a ping frame to the connection.
|
WebSocketBase |
ServerWebSocket.writePong(Buffer data)
Writes a pong frame to the connection.
|
WebSocketBase |
WebSocket.writePong(Buffer data)
Writes a pong frame to the connection.
|
WebSocketBase |
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.
|
WebSocketBase |
WebSocketBase.binaryMessageHandler(Handler<Buffer> handler)
Set a binary message handler on the connection.
|
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) |
WebSocketBase |
WebSocketBase.handler(Handler<Buffer> handler) |
HttpConnection |
HttpConnection.ping(Buffer data,
Handler<AsyncResult<Buffer>> pongHandler)
Send a frame to the remote endpoint.
|
HttpConnection |
HttpConnection.pingHandler(Handler<Buffer> handler)
Set an handler notified when a frame is received from the remote endpoint.
|
void |
HttpClientResponse.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
ServerWebSocket.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
WebSocket.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
HttpServerFileUpload.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
HttpServerRequest.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
WebSocketBase.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
HttpClientResponse.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
void |
ServerWebSocket.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
void |
WebSocket.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
void |
HttpServerFileUpload.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
void |
HttpServerRequest.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
void |
WebSocketBase.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
Observable<Void> |
HttpClientResponse.pipeToObservable(WriteStream<Buffer> dst)
|
Observable<Void> |
ServerWebSocket.pipeToObservable(WriteStream<Buffer> dst)
|
Observable<Void> |
WebSocket.pipeToObservable(WriteStream<Buffer> dst)
Deprecated.
|
Observable<Void> |
HttpServerFileUpload.pipeToObservable(WriteStream<Buffer> dst)
|
Observable<Void> |
HttpServerRequest.pipeToObservable(WriteStream<Buffer> dst)
|
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.
|
WebSocketBase |
WebSocketBase.pongHandler(Handler<Buffer> handler)
Set a pong frame handler on the connection.
|
Single<Void> |
HttpClientResponse.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Single<Void> |
ServerWebSocket.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Single<Void> |
WebSocket.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Single<Void> |
HttpServerFileUpload.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
Single<Void> |
HttpServerRequest.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
| 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 .
|
Observable<Buffer> |
NetSocket.toObservable() |
io.vertx.rx.java.WriteStreamSubscriber<Buffer> |
NetSocket.toSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
void |
NetSocket.end(Buffer data)
Same as
NetSocket.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
void |
NetSocket.end(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as but with an
handler called when the operation completes |
Observable<Void> |
NetSocket.endObservable(Buffer data)
Deprecated.
|
Single<Void> |
NetSocket.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Single<Void> |
NetSocket.rxWrite(Buffer message)
Like but with an
handler called when the message has been written
or failed to be written. |
NetSocket |
NetSocket.write(Buffer data) |
NetSocket |
NetSocket.write(Buffer message,
Handler<AsyncResult<Void>> handler)
Like but with an
handler called when the message has been written
or failed to be written. |
Observable<Void> |
NetSocket.writeObservable(Buffer message)
Deprecated.
use
NetSocket.rxWrite(java.lang.String) instead |
| Modifier and Type | Method and Description |
|---|---|
NetSocket |
NetSocket.handler(Handler<Buffer> handler) |
void |
NetSocket.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
NetSocket.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
Observable<Void> |
NetSocket.pipeToObservable(WriteStream<Buffer> dst)
Deprecated.
|
Single<Void> |
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 .
|
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,
Handler<Buffer> output)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava.core.buffer.Buffer>) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Observable<Buffer> stream)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava.core.buffer.Buffer>) but wraps the stream. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
ReadStream<Buffer> stream)
Like
RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.rxjava.core.buffer.Buffer>) but wraps the stream. |
JsonParser |
JsonParser.write(Buffer buffer)
Handle a
Buffer, pretty much like calling Handler. |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
OAuth2Response.body()
The HTTP response body as a buffer
|
| Modifier and Type | Method and Description |
|---|---|
AccessToken |
AccessToken.fetch(HttpMethod method,
String resource,
JsonObject headers,
Buffer payload,
Handler<AsyncResult<OAuth2Response>> callback)
Fetches a JSON resource using this Access Token.
|
Observable<OAuth2Response> |
AccessToken.fetchObservable(HttpMethod method,
String resource,
JsonObject headers,
Buffer payload)
Deprecated.
use
AccessToken.rxFetch(java.lang.String) instead |
Single<OAuth2Response> |
AccessToken.rxFetch(HttpMethod method,
String resource,
JsonObject headers,
Buffer payload)
Fetches a JSON resource using this Access Token.
|
| Modifier and Type | Method and Description |
|---|---|
StompClientConnection |
StompClientConnection.send(Map<String,String> headers,
Buffer body)
Sends a
SEND frame to the server. |
StompClientConnection |
StompClientConnection.send(Map<String,String> headers,
Buffer body,
Handler<Frame> receiptHandler)
Sends a
SEND frame to the server. |
StompClientConnection |
StompClientConnection.send(String destination,
Buffer body)
Sends a
SEND frame to the server to the given destination. |
StompClientConnection |
StompClientConnection.send(String destination,
Buffer body,
Handler<Frame> receiptHandler)
Sends a
SEND frame to the server to the given destination. |
StompClientConnection |
StompClientConnection.send(String destination,
Map<String,String> headers,
Buffer body)
Sends a
SEND frame to the server to the given destination. |
StompClientConnection |
StompClientConnection.send(String destination,
Map<String,String> headers,
Buffer body,
Handler<Frame> receiptHandler)
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 |
RoutingContext.getBody() |
| Modifier and Type | Method and Description |
|---|---|
void |
RoutingContext.setBody(Buffer body)
Set the body.
|
| 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(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.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.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(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.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.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(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.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.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(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.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.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(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.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.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(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.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.raw(String customHttpMethod,
int port,
String host,
String requestURI)
Create a request with a custom HTTP method to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.raw(String customHttpMethod,
String requestURI)
Create a request with a custom HTTP method to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.raw(String customHttpMethod,
String host,
String requestURI)
Create a request with a custom HTTP method to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.rawAbs(String customHttpMethod,
String absoluteURI)
Create a request with a custom HTTP method 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,
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,
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,
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.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,
String 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(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.ext.web.client.HttpResponse<T>>>) but with an HTTP request body buffer. |
void |
HttpRequest.sendBuffer(Buffer body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.ext.web.client.HttpResponse<T>>>) but with an HTTP request body buffer. |
Observable<HttpResponse<T>> |
HttpRequest.sendBufferObservable(Buffer body)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
HttpResponse<Buffer> |
ResponsePredicateResult.response()
The which has been tested.
|
| 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 |
|---|---|
Observable<Buffer> |
TemplateEngine.renderObservable(JsonObject context,
String templateFileName)
Deprecated.
|
Observable<Buffer> |
TemplateEngine.renderObservable(Map<String,Object> context,
String templateFileName)
Deprecated.
|
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 |
|---|---|
void |
TemplateEngine.render(JsonObject context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
void |
TemplateEngine.render(Map<String,Object> context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
| Modifier and Type | Method and Description |
|---|---|
ReadStream<Buffer> |
SockJSSocket.fetch(long amount)
Fetch the specified
amount of elements. |
Pipe<Buffer> |
SockJSSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Observable<Buffer> |
SockJSSocket.toObservable() |
io.vertx.rx.java.WriteStreamSubscriber<Buffer> |
SockJSSocket.toSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
void |
SockJSSocket.end(Buffer data)
Same as
SockJSSocket.end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but writes some data to the stream before ending. |
void |
SockJSSocket.end(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as but with an
handler called when the operation completes |
Observable<Void> |
SockJSSocket.endObservable(Buffer data)
Deprecated.
use
SockJSSocket.rxEnd() instead |
Single<Void> |
SockJSSocket.rxEnd(Buffer data)
Same as but with an
handler called when the operation completes |
Single<Void> |
SockJSSocket.rxWrite(Buffer data) |
SockJSSocket |
SockJSSocket.write(Buffer data) |
SockJSSocket |
SockJSSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
Observable<Void> |
SockJSSocket.writeObservable(Buffer data)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
SockJSSocket |
SockJSSocket.handler(Handler<Buffer> handler) |
void |
SockJSSocket.pipeTo(WriteStream<Buffer> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
SockJSSocket.pipeTo(WriteStream<Buffer> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
Observable<Void> |
SockJSSocket.pipeToObservable(WriteStream<Buffer> dst)
|
Single<Void> |
SockJSSocket.rxPipeTo(WriteStream<Buffer> dst)
Pipe this
ReadStream to the WriteStream. |
| Modifier and Type | Method and Description |
|---|---|
Observable<Buffer> |
TemplateEngine.renderObservable(RoutingContext context,
String templateFileName)
Deprecated.
|
Observable<Buffer> |
TemplateEngine.renderObservable(RoutingContext context,
String templateDirectory,
String templateFileName)
Deprecated.
|
Single<Buffer> |
TemplateEngine.rxRender(RoutingContext context,
String templateFileName)
Deprecated.
|
Single<Buffer> |
TemplateEngine.rxRender(RoutingContext context,
String templateDirectory,
String templateFileName)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
void |
TemplateEngine.render(RoutingContext context,
String templateDirectory,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
| 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 |
|---|---|
MqttClient |
MqttClient.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT client
|
MqttClient |
MqttClient.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server
|
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server
|
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
Single<Integer> |
MqttClient.rxPublish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
Single<Integer> |
MqttEndpoint.rxPublish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
Single<Integer> |
MqttEndpoint.rxPublish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId)
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 |
|---|---|
Buffer |
RabbitMQMessage.body() |
| Modifier and Type | Method and Description |
|---|---|
Observable<Buffer> |
RedisTransaction.getBinaryObservable(String key)
Deprecated.
use
RedisTransaction.rxGetBinary(java.lang.String) instead |
Observable<Buffer> |
RedisClient.getBinaryObservable(String key)
Deprecated.
use
RedisClient.rxGetBinary(java.lang.String) instead |
Single<Buffer> |
RedisTransaction.rxGetBinary(String key)
Get the value of a key - without decoding as utf-8
|
Single<Buffer> |
RedisClient.rxGetBinary(String key)
Get the value of a key - without decoding as utf-8
|
| Modifier and Type | Method and Description |
|---|---|
Single<String> |
RedisTransaction.rxSetBinary(String key,
Buffer value)
Set the binary string value of a key - without encoding as utf-8
|
Single<Void> |
RedisClient.rxSetBinary(String key,
Buffer value)
Set the binary string value of a key - without encoding as utf-8
|
Single<String> |
RedisTransaction.rxSetBinaryWithOptions(String key,
Buffer value,
SetOptions options)
Set the string value of a key
|
Single<Void> |
RedisClient.rxSetBinaryWithOptions(String key,
Buffer value,
SetOptions options)
Set the string value of a key
|
RedisTransaction |
RedisTransaction.setBinary(String key,
Buffer value,
Handler<AsyncResult<String>> handler)
Set the binary string value of a key - without encoding as utf-8
|
RedisClient |
RedisClient.setBinary(String key,
Buffer value,
Handler<AsyncResult<Void>> handler)
Set the binary string value of a key - without encoding as utf-8
|
Observable<String> |
RedisTransaction.setBinaryObservable(String key,
Buffer value)
Deprecated.
|
Observable<Void> |
RedisClient.setBinaryObservable(String key,
Buffer value)
Deprecated.
|
RedisTransaction |
RedisTransaction.setBinaryWithOptions(String key,
Buffer value,
SetOptions options,
Handler<AsyncResult<String>> handler)
Set the string value of a key
|
RedisClient |
RedisClient.setBinaryWithOptions(String key,
Buffer value,
SetOptions options,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
Observable<String> |
RedisTransaction.setBinaryWithOptionsObservable(String key,
Buffer value,
SetOptions options)
|
Observable<Void> |
RedisClient.setBinaryWithOptionsObservable(String key,
Buffer value,
SetOptions options)
|
| Modifier and Type | Method and Description |
|---|---|
RedisTransaction |
RedisTransaction.getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Get the value of a key - without decoding as utf-8
|
RedisClient |
RedisClient.getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Get the value of a key - without decoding as utf-8
|
| 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 name)
Get a buffer value at
pos. |
| Modifier and Type | Method and Description |
|---|---|
Tuple |
Tuple.addBuffer(Buffer value)
Add a buffer value at the end of the tuple.
|
Copyright © 2020 Eclipse. All rights reserved.