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 | 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.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(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 |
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.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 |
---|---|
void |
PacketWritestream.end(Buffer t)
Same as
WriteStream.end() but writes some data to the stream before ending. |
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)
Write the given
Buffer to the SocketAddress . |
PacketWritestream |
PacketWritestream.write(Buffer data) |
Modifier and Type | Method and Description |
---|---|
Buffer |
FileSystem.readFileBlocking(String path)
|
Modifier and Type | Method and Description |
---|---|
Observable<Buffer> |
FileSystem.readFileObservable(String path)
Reads the entire file as represented by the path
path as a , asynchronously. |
Observable<Buffer> |
AsyncFile.readObservable(Buffer buffer,
int offset,
long position,
int length)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
Observable<Buffer> |
AsyncFile.toObservable() |
Modifier and Type | Method and Description |
---|---|
void |
AsyncFile.end(Buffer t)
Same as
AsyncFile.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
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)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
AsyncFile |
AsyncFile.write(Buffer data) |
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)
Creates the file, and writes the specified
Buffer data to the file represented by the path path ,
asynchronously. |
Observable<Void> |
AsyncFile.writeObservable(Buffer buffer,
long position)
Write a
Buffer to the file at position position in the file, asynchronously. |
Modifier and Type | Method and Description |
---|---|
AsyncFile |
AsyncFile.handler(Handler<Buffer> handler) |
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. |
Modifier and Type | Method and Description |
---|---|
Buffer |
WebSocketFrame.binaryData() |
Buffer |
HttpFrame.payload() |
Modifier and Type | Method and Description |
---|---|
Observable<Buffer> |
HttpConnection.pingObservable(Buffer data)
Send a frame to the remote endpoint.
|
Observable<Buffer> |
HttpClientResponse.toObservable() |
Observable<Buffer> |
HttpServerFileUpload.toObservable() |
Observable<Buffer> |
HttpServerRequest.toObservable() |
Observable<Buffer> |
ServerWebSocket.toObservable() |
Observable<Buffer> |
WebSocket.toObservable() |
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 |
HttpClientRequest.end(Buffer chunk)
Same as
HttpClientRequest.end(java.lang.String) but writes some data to the request body before ending. |
void |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse.end(java.lang.String) but writes some data to the response body before ending. |
void |
ServerWebSocket.end(Buffer t)
Same as
WebSocketBase.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
void |
WebSocket.end(Buffer t)
Same as
WebSocketBase.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
void |
WebSocketBase.end(Buffer t)
Same as
WebSocketBase.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
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.
|
Observable<Buffer> |
HttpConnection.pingObservable(Buffer data)
Send a frame to the remote endpoint.
|
HttpClientRequest |
HttpClientRequest.write(Buffer data) |
HttpServerResponse |
HttpServerResponse.write(Buffer data) |
ServerWebSocket |
ServerWebSocket.write(Buffer data) |
WebSocket |
WebSocket.write(Buffer data) |
WebSocketBase |
WebSocketBase.write(Buffer data) |
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.
|
HttpClientRequest |
HttpClientRequest.writeCustomFrame(int type,
int flags,
Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.
|
HttpServerResponse |
HttpServerResponse.writeCustomFrame(int type,
int flags,
Buffer payload)
Write an HTTP/2 frame to the response, 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
|
Modifier and Type | Method and Description |
---|---|
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) |
HttpServerFileUpload |
HttpServerFileUpload.handler(Handler<Buffer> handler) |
HttpServerRequest |
HttpServerRequest.handler(Handler<Buffer> handler) |
ServerWebSocket |
ServerWebSocket.handler(Handler<Buffer> handler) |
WebSocket |
WebSocket.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.
|
Modifier and Type | Method and Description |
---|---|
Observable<Buffer> |
NetSocket.toObservable() |
Modifier and Type | Method and Description |
---|---|
void |
NetSocket.end(Buffer t)
Same as
NetSocket.end(io.vertx.rxjava.core.buffer.Buffer) but writes some data to the stream before ending. |
NetSocket |
NetSocket.write(Buffer data) |
Modifier and Type | Method and Description |
---|---|
NetSocket |
NetSocket.handler(Handler<Buffer> handler) |
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.
|
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Handler<Buffer> output)
Create a new
RecordParser instance, initially in delimited mode, and where the delimiter can be represented
by the Buffer delim. |
Modifier and Type | Method and Description |
---|---|
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Handler<Buffer> output)
Create a new
RecordParser instance, initially in delimited mode, and where the delimiter can be represented
by the Buffer delim. |
static RecordParser |
RecordParser.newDelimited(String delim,
Handler<Buffer> output)
Create a new
RecordParser instance, initially in delimited mode, and where the delimiter can be represented
by the String delim endcoded in latin-1 . |
static RecordParser |
RecordParser.newFixed(int size,
Handler<Buffer> output)
Create a new
RecordParser instance, initially in fixed size mode, and where the record size is specified
by the size parameter. |
void |
RecordParser.setOutput(Handler<Buffer> output) |
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 |
---|---|
Observable<Buffer> |
SockJSSocket.toObservable() |
Modifier and Type | Method and Description |
---|---|
void |
SockJSSocket.end(Buffer t) |
SockJSSocket |
SockJSSocket.write(Buffer data) |
Modifier and Type | Method and Description |
---|---|
SockJSSocket |
SockJSSocket.handler(Handler<Buffer> handler) |
Modifier and Type | Method and Description |
---|---|
Observable<Buffer> |
TemplateEngine.renderObservable(RoutingContext context,
String templateFileName)
Render
|
Modifier and Type | Method and Description |
---|---|
void |
TemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render
|
Modifier and Type | Method and Description |
---|---|
Observable<Buffer> |
RedisClient.getBinaryObservable(String key)
Get the value of a key - without decoding as utf-8
|
Modifier and Type | Method and Description |
---|---|
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<Void> |
RedisClient.setBinaryObservable(String key,
Buffer value)
Set the binary string value of a key - without encoding as utf-8
|
Observable<String> |
RedisTransaction.setBinaryObservable(String key,
Buffer value)
Set the binary string value of a key - without encoding as utf-8
|
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<Void> |
RedisClient.setBinaryWithOptionsObservable(String key,
Buffer value,
SetOptions options)
Set the string value of a key
|
Observable<String> |
RedisTransaction.setBinaryWithOptionsObservable(String key,
Buffer value,
SetOptions options)
Set the string value of a key
|
Modifier and Type | Method and Description |
---|---|
RedisClient |
RedisClient.getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Get the value of a key - without decoding as utf-8
|
Copyright © 2016. All rights reserved.