Modifier and Type | Method and Description |
---|---|
static <T> rx.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.appendLong(long l)
Appends the specified
long to the end of the Buffer. |
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.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 . |
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.setLong(int pos,
long l)
Sets the
long at position pos in the Buffer to the value l . |
Buffer |
Buffer.setShort(int pos,
short s)
Sets the
short at position pos in the Buffer to the value s . |
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.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 |
---|---|
DatagramSocket |
DatagramSocket.send(Buffer packet,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
Buffer to the SocketAddress . |
rx.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)
Blocking version of
FileSystem |
Modifier and Type | Method and Description |
---|---|
rx.Observable<Buffer> |
FileSystem.readFileObservable(String path)
Reads the entire file as represented by the path
path as a , asynchronously. |
rx.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. |
rx.Observable<Buffer> |
AsyncFile.toObservable() |
Modifier and Type | Method and Description |
---|---|
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. |
rx.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)
Blocking version of
FileSystem |
rx.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. |
rx.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() |
Modifier and Type | Method and Description |
---|---|
rx.Observable<Buffer> |
HttpClientResponse.toObservable() |
rx.Observable<Buffer> |
HttpServerFileUpload.toObservable() |
rx.Observable<Buffer> |
HttpServerRequest.toObservable() |
rx.Observable<Buffer> |
ServerWebSocket.toObservable() |
rx.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 but writes some data to the request body before ending. |
void |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse but writes some data to the response body before ending. |
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.
|
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) |
Modifier and Type | Method and Description |
---|---|
rx.Observable<Buffer> |
NetSocket.toObservable() |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
Buffer |
RoutingContext.getBody() |
Modifier and Type | Method and Description |
---|---|
void |
RoutingContext.setBody(Buffer body)
Set the body.
|
Modifier and Type | Method and Description |
---|---|
rx.Observable<Buffer> |
SockJSSocket.toObservable() |
Modifier and Type | Method and Description |
---|---|
SockJSSocket |
SockJSSocket.write(Buffer data) |
Modifier and Type | Method and Description |
---|---|
SockJSSocket |
SockJSSocket.handler(Handler<Buffer> handler) |
Modifier and Type | Method and Description |
---|---|
rx.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
|
Copyright © 2015. All Rights Reserved.