Uses of Interface
io.vertx.core.buffer.Buffer
-
-
Uses of Buffer in io.vertx.amqp
Methods in io.vertx.amqp that return Buffer Modifier and Type Method Description Buffer
AmqpMessage. bodyAsBinary()
Methods in io.vertx.amqp with parameters of type Buffer Modifier and Type Method Description AmqpClientOptions
AmqpClientOptions. addCrlValue(Buffer crlValue)
AmqpMessageBuilder
AmqpMessageBuilder. withBufferAsBody(Buffer buffer)
-
Uses of Buffer in io.vertx.config.consul
Methods in io.vertx.config.consul that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
ConsulConfigStore. get()
-
Uses of Buffer in io.vertx.config.git
Methods in io.vertx.config.git that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
GitConfigStore. get()
-
Uses of Buffer in io.vertx.config.hocon
Methods in io.vertx.config.hocon with parameters of type Buffer Modifier and Type Method Description Future<JsonObject>
HoconProcessor. process(Vertx vertx, JsonObject configuration, Buffer input)
-
Uses of Buffer in io.vertx.config.kubernetes
Methods in io.vertx.config.kubernetes that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
ConfigMapStore. get()
-
Uses of Buffer in io.vertx.config.redis
Methods in io.vertx.config.redis that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
RedisConfigStore. get()
-
Uses of Buffer in io.vertx.config.spi
Methods in io.vertx.config.spi that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
ConfigStore. get()
Retrieves the configuration store in this store.Methods in io.vertx.config.spi with parameters of type Buffer Modifier and Type Method Description Future<JsonObject>
ConfigProcessor. process(Vertx vertx, JsonObject configuration, Buffer input)
Transforms the giveninput
into aJsonObject
. -
Uses of Buffer in io.vertx.config.spi.utils
Methods in io.vertx.config.spi.utils that return Buffer Modifier and Type Method Description static Buffer
JsonObjectHelper. toBuffer(JsonObject json)
Deprecated.useJsonObject.toBuffer()
instead -
Uses of Buffer in io.vertx.config.vault
Methods in io.vertx.config.vault that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
VaultConfigStore. get()
-
Uses of Buffer in io.vertx.config.yaml
Methods in io.vertx.config.yaml with parameters of type Buffer Modifier and Type Method Description Future<JsonObject>
YamlProcessor. process(Vertx vertx, JsonObject configuration, Buffer input)
-
Uses of Buffer in io.vertx.config.zookeeper
Methods in io.vertx.config.zookeeper that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
ZookeeperConfigStore. get()
-
Uses of Buffer in io.vertx.core.buffer
Methods in io.vertx.core.buffer that return Buffer Modifier and Type Method Description Buffer
Buffer. appendBuffer(Buffer buff)
Appends the specifiedBuffer
to the end of this Buffer.Buffer
Buffer. appendBuffer(Buffer buff, int offset, int len)
Appends the specifiedBuffer
starting at theoffset
usinglen
to the end of this Buffer.Buffer
Buffer. appendByte(byte b)
Appends the specifiedbyte
to the end of the Buffer.Buffer
Buffer. appendBytes(byte[] bytes)
Appends the specifiedbyte[]
to the end of the Buffer.Buffer
Buffer. appendBytes(byte[] bytes, int offset, int len)
Appends the specified number of bytes frombyte[]
to the end of the Buffer, starting at the given offset.Buffer
Buffer. appendDouble(double d)
Appends the specifieddouble
to the end of the Buffer.Buffer
Buffer. appendDoubleLE(double d)
Appends the specified unsigneddouble
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. appendFloat(float f)
Appends the specifiedfloat
to the end of the Buffer.Buffer
Buffer. appendFloatLE(float f)
Appends the specified unsignedfloat
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. appendInt(int i)
Appends the specifiedint
to the end of the Buffer.Buffer
Buffer. appendIntLE(int i)
Appends the specifiedint
to the end of the Buffer in the Little Endian Byte Order.Buffer
Buffer. appendLong(long l)
Appends the specifiedlong
to the end of the Buffer.Buffer
Buffer. appendLongLE(long l)
Appends the specifiedlong
to the end of the Buffer in the Little Endian Byte Order.Buffer
Buffer. appendMedium(int i)
Appends the specified 24bitint
to the end of the Buffer.Buffer
Buffer. appendMediumLE(int i)
Appends the specified 24bitint
to the end of the Buffer in the Little Endian Byte Order.Buffer
Buffer. appendShort(short s)
Appends the specifiedshort
to the end of the Buffer.The buffer will expand as necessary to accommodate any bytes written.Buffer
Buffer. appendShortLE(short s)
Appends the specifiedshort
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 specifiedString str
to the end of the Buffer with UTF-8 encoding.Buffer
Buffer. appendString(String str, String enc)
Appends the specifiedString
to the end of the Buffer with the encoding as specified byenc
.Buffer
Buffer. appendUnsignedByte(short b)
Appends the specified unsignedbyte
to the end of the Buffer.Buffer
Buffer. appendUnsignedInt(long i)
Appends the specified unsignedint
to the end of the Buffer.Buffer
Buffer. appendUnsignedIntLE(long i)
Appends the specified unsignedint
to the end of the Buffer in the Little Endian Byte Order.Buffer
Buffer. appendUnsignedShort(int s)
Appends the specified unsignedshort
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 unsignedshort
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(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.static Buffer
Buffer. fromJson(String value)
Create a buffer from the base 64 URL encodedvalue
Buffer
Buffer. getBuffer(int start, int end)
Returns a copy of a sub-sequence the Buffer as aBuffer
starting at positionstart
and ending at positionend - 1
Buffer
Buffer. getBytes(byte[] dst)
Transfers the content of the Buffer into abyte[]
.Buffer
Buffer. getBytes(byte[] dst, int dstIndex)
Transfers the content of the Buffer into abyte[]
at the specific destination.Buffer
Buffer. getBytes(int start, int end, byte[] dst)
Transfers the content of the Buffer starting at positionstart
and ending at positionend - 1
into abyte[]
.Buffer
Buffer. getBytes(int start, int end, byte[] dst, int dstIndex)
Transfers the content of the Buffer starting at positionstart
and ending at positionend - 1
into abyte[]
at the specific destination.Buffer
Buffer. setBuffer(int pos, Buffer b)
Sets the bytes at positionpos
in the Buffer to the bytes represented by theBuffer b
.Buffer
Buffer. setBuffer(int pos, Buffer b, int offset, int len)
Sets the bytes at positionpos
in the Buffer to the bytes represented by theBuffer b
on the givenoffset
andlen
.Buffer
Buffer. setByte(int pos, byte b)
Sets thebyte
at positionpos
in the Buffer to the valueb
.Buffer
Buffer. setBytes(int pos, byte[] b)
Sets the bytes at positionpos
in the Buffer to the bytes represented by thebyte[] b
.Buffer
Buffer. setBytes(int pos, byte[] b, int offset, int len)
Sets the given number of bytes at positionpos
in the Buffer to the bytes represented by thebyte[] b
.Buffer
Buffer. setBytes(int pos, ByteBuffer b)
Sets the bytes at positionpos
in the Buffer to the bytes represented by theByteBuffer b
.Buffer
Buffer. setDouble(int pos, double d)
Sets thedouble
at positionpos
in the Buffer to the valued
.Buffer
Buffer. setDoubleLE(int pos, double d)
Sets thedouble
at positionpos
in the Buffer to the valued
in the Little Endian Byte Order.Buffer
Buffer. setFloat(int pos, float f)
Sets thefloat
at positionpos
in the Buffer to the valuef
.Buffer
Buffer. setFloatLE(int pos, float f)
Sets thefloat
at positionpos
in the Buffer to the valuef
in the Little Endian Byte Order.Buffer
Buffer. setInt(int pos, int i)
Sets theint
at positionpos
in the Buffer to the valuei
.Buffer
Buffer. setIntLE(int pos, int i)
Sets theint
at positionpos
in the Buffer to the valuei
in the Little Endian Byte Order.Buffer
Buffer. setLong(int pos, long l)
Sets thelong
at positionpos
in the Buffer to the valuel
.Buffer
Buffer. setLongLE(int pos, long l)
Sets thelong
at positionpos
in the Buffer to the valuel
in the Little Endian Byte Order.Buffer
Buffer. setMedium(int pos, int i)
Sets the 24bitint
at positionpos
in the Buffer to the valuei
.Buffer
Buffer. setMediumLE(int pos, int i)
Sets the 24bitint
at positionpos
in the Buffer to the valuei
.Buffer
Buffer. setShort(int pos, short s)
Sets theshort
at positionpos
in the Buffer to the values
.Buffer
Buffer. setShortLE(int pos, short s)
Sets theshort
at positionpos
in the Buffer to the values
in the Little Endian Byte Order.Buffer
Buffer. setString(int pos, String str)
Sets the bytes at positionpos
in the Buffer to the value ofstr
encoded in UTF-8.Buffer
Buffer. setString(int pos, String str, String enc)
Sets the bytes at positionpos
in the Buffer to the value ofstr
encoded in encodingenc
.Buffer
Buffer. setUnsignedByte(int pos, short b)
Sets the unsignedbyte
at positionpos
in the Buffer to the valueb
.Buffer
Buffer. setUnsignedInt(int pos, long i)
Sets the unsignedint
at positionpos
in the Buffer to the valuei
.Buffer
Buffer. setUnsignedIntLE(int pos, long i)
Sets the unsignedint
at positionpos
in the Buffer to the valuei
in the Little Endian Byte Order.Buffer
Buffer. setUnsignedShort(int pos, int s)
Sets the unsignedshort
at positionpos
in the Buffer to the values
.Buffer
Buffer. setUnsignedShortLE(int pos, int s)
Sets the unsignedshort
at positionpos
in the Buffer to the values
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.Methods in io.vertx.core.buffer with parameters of type Buffer Modifier and Type Method Description Buffer
Buffer. appendBuffer(Buffer buff)
Appends the specifiedBuffer
to the end of this Buffer.Buffer
Buffer. appendBuffer(Buffer buff, int offset, int len)
Appends the specifiedBuffer
starting at theoffset
usinglen
to the end of this Buffer.Buffer
Buffer. setBuffer(int pos, Buffer b)
Sets the bytes at positionpos
in the Buffer to the bytes represented by theBuffer b
.Buffer
Buffer. setBuffer(int pos, Buffer b, int offset, int len)
Sets the bytes at positionpos
in the Buffer to the bytes represented by theBuffer b
on the givenoffset
andlen
. -
Uses of Buffer in io.vertx.core.datagram
Methods in io.vertx.core.datagram that return Buffer Modifier and Type Method Description Buffer
DatagramPacket. data()
Returns the data of theDatagramPacket
Methods in io.vertx.core.datagram that return types with arguments of type Buffer Modifier and Type Method Description WriteStream<Buffer>
DatagramSocket. sender(int port, String host)
Methods in io.vertx.core.datagram with parameters of type Buffer Modifier and Type Method Description Future<Void>
DatagramSocket. send(Buffer packet, int port, String host)
Write the givenBuffer
to theSocketAddress
. -
Uses of Buffer in io.vertx.core.dns
Methods in io.vertx.core.dns that return Buffer Modifier and Type Method Description Buffer
AddressResolverOptions. getHostsValue()
Methods in io.vertx.core.dns with parameters of type Buffer Modifier and Type Method Description AddressResolverOptions
AddressResolverOptions. setHostsValue(Buffer hostsValue)
Set an alternate hosts configuration file to use instead of the one provided by the os. -
Uses of Buffer in io.vertx.core.eventbus
Methods in io.vertx.core.eventbus with parameters of type Buffer Modifier and Type Method Description EventBusOptions
EventBusOptions. addCrlValue(Buffer crlValue)
R
MessageCodec. decodeFromWire(int pos, Buffer buffer)
Called by Vert.x when a message is decoded from the wire.void
MessageCodec. encodeToWire(Buffer buffer, S s)
Called by Vert.x when marshalling a message to the wire. -
Uses of Buffer in io.vertx.core.file
Methods in io.vertx.core.file that return Buffer Modifier and Type Method Description Buffer
FileSystem. readFileBlocking(String path)
Blocking version ofFileSystem.readFile(String)
Methods in io.vertx.core.file that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
AsyncFile. read(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Future<Buffer>
FileSystem. readFile(String path)
Reads the entire file as represented by the pathpath
as aBuffer
, asynchronously.Methods in io.vertx.core.file with parameters of type Buffer Modifier and Type Method Description Future<Buffer>
AsyncFile. read(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Future<Void>
AsyncFile. write(Buffer buffer, long position)
Write aBuffer
to the file at positionposition
in the file, asynchronously.Future<Void>
FileSystem. writeFile(String path, Buffer data)
Creates the file, and writes the specifiedBuffer data
to the file represented by the pathpath
, asynchronously.FileSystem
FileSystem. writeFileBlocking(String path, Buffer data)
Blocking version ofFileSystem.writeFile(String, Buffer)
Method parameters in io.vertx.core.file with type arguments of type Buffer Modifier and Type Method Description AsyncFile
AsyncFile. handler(Handler<Buffer> handler)
-
Uses of Buffer in io.vertx.core.http
Methods in io.vertx.core.http that return Buffer Modifier and Type Method Description Buffer
WebSocketFrame. binaryData()
Buffer
UpgradeRejectedException. getBody()
Buffer
GoAway. getDebugData()
Buffer
HttpFrame. payload()
Methods in io.vertx.core.http that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
HttpClientResponse. body()
Convenience method for receiving the entire request body in one piece.Future<Buffer>
HttpServerRequest. body()
Convenience method for receiving the entire request body in one piece.Future<Buffer>
HttpConnection. ping(Buffer data)
Send a PING frame to the remote endpoint.Methods in io.vertx.core.http with parameters of type Buffer Modifier and Type Method Description HttpClientOptions
HttpClientOptions. addCrlValue(Buffer crlValue)
HttpServerOptions
HttpServerOptions. addCrlValue(Buffer crlValue)
WebSocketClientOptions
WebSocketClientOptions. addCrlValue(Buffer crlValue)
static WebSocketFrame
WebSocketFrame. binaryFrame(Buffer data, boolean isFinal)
Create a binary WebSocket frame.static WebSocketFrame
WebSocketFrame. continuationFrame(Buffer data, boolean isFinal)
Create a continuation frameFuture<Void>
HttpClientRequest. end(Buffer chunk)
Same asHttpClientRequest.end()
but writes some data to the request body before ending.Future<Void>
HttpServerResponse. end(Buffer chunk)
Same asHttpServerResponse.end()
but writes some data to the response body before ending.HttpConnection
HttpConnection. goAway(long errorCode, int lastStreamId, Buffer debugData)
Send a go away frame to the remote endpoint of the connection.Future<Buffer>
HttpConnection. ping(Buffer data)
Send a PING 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.default Future<HttpClientResponse>
HttpClientRequest. send(Buffer body)
Send the request with a bufferbody
.default Future<Void>
HttpServerResponse. send(Buffer body)
Send the request with a bufferbody
.GoAway
GoAway. setDebugData(Buffer debugData)
Set the additional debug dataFuture<Void>
WebSocketBase. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Future<Void>
HttpClientRequest. writeCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.Future<Void>
HttpServerResponse. writeCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.Future<Void>
WebSocketBase. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionFuture<Void>
WebSocketBase. writePing(Buffer data)
Writes a ping frame to the connection.Future<Void>
WebSocketBase. writePong(Buffer data)
Writes a pong frame to the connection.Method parameters in io.vertx.core.http with type arguments of type Buffer Modifier and Type Method Description ClientWebSocket
ClientWebSocket. binaryMessageHandler(Handler<Buffer> handler)
WebSocket
WebSocket. binaryMessageHandler(Handler<Buffer> handler)
WebSocketBase
WebSocketBase. binaryMessageHandler(Handler<Buffer> handler)
Set a binary message handler on the connection.default HttpClientResponse
HttpClientResponse. bodyHandler(Handler<Buffer> bodyHandler)
Convenience method for receiving the entire request body in one piece.default HttpServerRequest
HttpServerRequest. bodyHandler(Handler<Buffer> bodyHandler)
Convenience method for receiving the entire request body in one piece.ClientWebSocket
ClientWebSocket. handler(Handler<Buffer> handler)
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. pingHandler(Handler<Buffer> handler)
Set an handler notified when a PING frame is received from the remote endpoint.ClientWebSocket
ClientWebSocket. pongHandler(Handler<Buffer> handler)
WebSocket
WebSocket. pongHandler(Handler<Buffer> handler)
WebSocketBase
WebSocketBase. pongHandler(Handler<Buffer> handler)
Set a pong frame handler on the connection.default Future<HttpClientResponse>
HttpClientRequest. send(ReadStream<Buffer> body)
Send the request with a streambody
.default Future<Void>
HttpServerResponse. send(ReadStream<Buffer> body)
Send the request with a streambody
.Constructors in io.vertx.core.http with parameters of type Buffer Constructor Description UpgradeRejectedException(String message, int status, MultiMap headers, Buffer content)
-
Uses of Buffer in io.vertx.core.json
Methods in io.vertx.core.json that return Buffer Modifier and Type Method Description static Buffer
Json. encodeToBuffer(Object obj)
Encode a POJO to JSON using the underlying Jackson mapper.Buffer
JsonArray. getBuffer(int pos)
Get the Buffer at positionpos
in the array.Buffer
JsonObject. getBuffer(String key)
Get theBuffer
value with the specified key.Buffer
JsonObject. getBuffer(String key, Buffer def)
LikeJsonObject.getBuffer(String)
but specifying a default value to return if there is no entry.Buffer
JsonArray. toBuffer()
Encode this JSON object as buffer.Buffer
JsonObject. toBuffer()
Encode this JSON object as buffer.Methods in io.vertx.core.json with parameters of type Buffer Modifier and Type Method Description static Object
Json. decodeValue(Buffer buf)
Decode a given JSON buffer.static <T> T
Json. decodeValue(Buffer buf, Class<T> clazz)
Decode a given JSON buffer to a POJO of the given class type.Buffer
JsonObject. getBuffer(String key, Buffer def)
LikeJsonObject.getBuffer(String)
but specifying a default value to return if there is no entry.int
JsonArray. readFromBuffer(int pos, Buffer buffer)
int
JsonObject. readFromBuffer(int pos, Buffer buffer)
void
JsonArray. writeToBuffer(Buffer buffer)
void
JsonObject. writeToBuffer(Buffer buffer)
Constructors in io.vertx.core.json with parameters of type Buffer Constructor Description JsonArray(Buffer buf)
Create an instance from a Buffer of JSON.JsonObject(Buffer buf)
Create an instance from a buffer. -
Uses of Buffer in io.vertx.core.json.jackson
Methods in io.vertx.core.json.jackson that return Buffer Modifier and Type Method Description Buffer
DatabindCodec. toBuffer(Object object, boolean pretty)
Buffer
JacksonCodec. toBuffer(Object object, boolean pretty)
Methods in io.vertx.core.json.jackson with parameters of type Buffer Modifier and Type Method Description static JsonParser
JacksonCodec. createParser(Buffer buf)
static <T> T
JacksonCodec. decodeValue(Buffer buf, TypeReference<T> type)
Decode a given JSON buffer to a POJO of the given class type.<T> T
DatabindCodec. fromBuffer(Buffer buf, TypeReference<T> typeRef)
<T> T
DatabindCodec. fromBuffer(Buffer buf, Class<T> clazz)
Object
JacksonCodec. fromBuffer(Buffer buf)
<T> T
JacksonCodec. fromBuffer(Buffer buf, TypeReference<T> typeRef)
<T> T
JacksonCodec. fromBuffer(Buffer json, Class<T> clazz)
-
Uses of Buffer in io.vertx.core.net
Methods in io.vertx.core.net that return Buffer Modifier and Type Method Description Buffer
PemKeyCertOptions. getCertValue()
Get the first certificate as a bufferBuffer
PemKeyCertOptions. getKeyValue()
Get the first key as a bufferBuffer
KeyStoreOptionsBase. getValue()
Get the key store as a bufferMethods in io.vertx.core.net that return types with arguments of type Buffer Modifier and Type Method Description List<Buffer>
PemKeyCertOptions. getCertValues()
Get all the certificates as a list of bufferList<Buffer>
PemTrustOptions. getCertValues()
List<Buffer>
SSLOptions. getCrlValues()
Get the CRL valuesList<Buffer>
TCPSSLOptions. getCrlValues()
Get the CRL valuesList<Buffer>
PemKeyCertOptions. getKeyValues()
Get all the keys as a list of bufferMethods in io.vertx.core.net with parameters of type Buffer Modifier and Type Method Description PemKeyCertOptions
PemKeyCertOptions. addCertValue(Buffer certValue)
Add a certificate as a bufferPemTrustOptions
PemTrustOptions. addCertValue(Buffer certValue)
Add a certificate valueClientOptionsBase
ClientOptionsBase. addCrlValue(Buffer crlValue)
NetClientOptions
NetClientOptions. addCrlValue(Buffer crlValue)
NetServerOptions
NetServerOptions. addCrlValue(Buffer crlValue)
ServerSSLOptions
ServerSSLOptions. addCrlValue(Buffer crlValue)
SSLOptions
SSLOptions. addCrlValue(Buffer crlValue)
Add a CRL valueTCPSSLOptions
TCPSSLOptions. addCrlValue(Buffer crlValue)
Add a CRL valuePemKeyCertOptions
PemKeyCertOptions. addKeyValue(Buffer keyValue)
Add a key as a bufferPemKeyCertOptions
PemKeyCertOptions. setCertValue(Buffer certValue)
Set the first certificate as a buffer, replacing the previous certificates buffersPemKeyCertOptions
PemKeyCertOptions. setKeyValue(Buffer keyValue)
Set the first key a a buffer, replacing the previous keys buffersJksOptions
JksOptions. setValue(Buffer value)
Set the key store as a bufferKeyStoreOptions
KeyStoreOptions. setValue(Buffer value)
KeyStoreOptionsBase
KeyStoreOptionsBase. setValue(Buffer value)
Set the key store as a bufferPfxOptions
PfxOptions. setValue(Buffer value)
Set the key store as a bufferdefault Future<Void>
NetSocket. upgradeToSsl(Buffer msg)
LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)
with the default SSL options and without indicating a server name.default Future<Void>
NetSocket. upgradeToSsl(SSLOptions sslOptions, Buffer msg)
LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)
without indicating a server nameFuture<Void>
NetSocket. upgradeToSsl(SSLOptions sslOptions, String serverName, Buffer upgrade)
Upgrade the channel to use SSL/TLS, in other words proceeds to the TLS handshake.default Future<Void>
NetSocket. upgradeToSsl(String serverName, Buffer msg)
LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)
with the default SSL options.Method parameters in io.vertx.core.net with type arguments of type Buffer Modifier and Type Method Description NetSocket
NetSocket. handler(Handler<Buffer> handler)
PemKeyCertOptions
PemKeyCertOptions. setCertValues(List<Buffer> certValues)
Set all the certificates as a list of bufferPemKeyCertOptions
PemKeyCertOptions. setKeyValues(List<Buffer> keyValues)
Set all the keys as a list of buffer -
Uses of Buffer in io.vertx.core.parsetools
Methods in io.vertx.core.parsetools that return Buffer Modifier and Type Method Description Buffer
JsonEvent. binaryValue()
Return the binary value.Methods in io.vertx.core.parsetools with parameters of type Buffer Modifier and Type Method Description void
RecordParser. delimitedMode(Buffer delim)
Flip the parser into delimited mode, and where the delimiter can be represented by the delimiterdelim
.void
RecordParser. handle(Buffer buffer)
This method is called to provide the parser with data.static RecordParser
RecordParser. newDelimited(Buffer delim)
Create a newRecordParser
instance, initially in delimited mode, and where the delimiter can be represented by theBuffer
delim.static RecordParser
RecordParser. newDelimited(Buffer delim, Handler<Buffer> output)
LikeRecordParser.newDelimited(Buffer)
but set theoutput
that will receive whole records which have been parsed.static RecordParser
RecordParser. newDelimited(Buffer delim, ReadStream<Buffer> stream)
LikeRecordParser.newDelimited(Buffer)
but wraps thestream
.JsonParser
JsonParser. write(Buffer buffer)
Handle aBuffer
, pretty much like callingHandler.handle(Object)
.Method parameters in io.vertx.core.parsetools with type arguments of type Buffer Modifier and Type Method Description RecordParser
RecordParser. handler(Handler<Buffer> handler)
static RecordParser
RecordParser. newDelimited(Buffer delim, Handler<Buffer> output)
LikeRecordParser.newDelimited(Buffer)
but set theoutput
that will receive whole records which have been parsed.static RecordParser
RecordParser. newDelimited(Buffer delim, ReadStream<Buffer> stream)
LikeRecordParser.newDelimited(Buffer)
but wraps thestream
.static RecordParser
RecordParser. newDelimited(String delim, Handler<Buffer> output)
LikeRecordParser.newDelimited(String)
but set theoutput
that will receive whole records which have been parsed.static RecordParser
RecordParser. newDelimited(String delim, ReadStream<Buffer> stream)
LikeRecordParser.newDelimited(String)
but wraps thestream
.static RecordParser
RecordParser. newFixed(int size, Handler<Buffer> output)
LikeRecordParser.newFixed(int)
but set theoutput
that will receive whole records which have been parsed.static RecordParser
RecordParser. newFixed(int size, ReadStream<Buffer> stream)
LikeRecordParser.newFixed(int)
but wraps thestream
.static JsonParser
JsonParser. newParser(ReadStream<Buffer> stream)
Create a newJsonParser
instance.void
RecordParser. setOutput(Handler<Buffer> output)
-
Uses of Buffer in io.vertx.core.shareddata
Methods in io.vertx.core.shareddata with parameters of type Buffer Modifier and Type Method Description int
ClusterSerializable. readFromBuffer(int pos, Buffer buffer)
Method invoked when deserializing bytes to this instance.void
ClusterSerializable. writeToBuffer(Buffer buffer)
Method invoked when serializing this instance. -
Uses of Buffer in io.vertx.core.spi.cluster
Methods in io.vertx.core.spi.cluster with parameters of type Buffer Modifier and Type Method Description int
NodeInfo. readFromBuffer(int start, Buffer buffer)
int
RegistrationInfo. readFromBuffer(int start, Buffer buffer)
void
NodeInfo. writeToBuffer(Buffer buffer)
void
RegistrationInfo. writeToBuffer(Buffer buffer)
-
Uses of Buffer in io.vertx.core.spi.json
Methods in io.vertx.core.spi.json that return Buffer Modifier and Type Method Description default Buffer
JsonCodec. toBuffer(Object object)
LikeJsonCodec.toString(Object)
but with a jsonBuffer
Buffer
JsonCodec. toBuffer(Object object, boolean pretty)
LikeJsonCodec.toString(Object, boolean)
but with a jsonBuffer
Methods in io.vertx.core.spi.json with parameters of type Buffer Modifier and Type Method Description <T> T
JsonCodec. fromBuffer(Buffer json, Class<T> clazz)
LikeJsonCodec.fromString(String, Class)
but with a jsonBuffer
-
Uses of Buffer in io.vertx.ext.auth
Methods in io.vertx.ext.auth that return Buffer Modifier and Type Method Description Buffer
PubSecKeyOptions. getBuffer()
The PEM or Secret key buffer.Methods in io.vertx.ext.auth with parameters of type Buffer Modifier and Type Method Description PubSecKeyOptions
PubSecKeyOptions. setBuffer(Buffer buffer)
The PEM or Secret key buffer. -
Uses of Buffer in io.vertx.ext.consul
Methods in io.vertx.ext.consul with parameters of type Buffer Modifier and Type Method Description ConsulClientOptions
ConsulClientOptions. addCrlValue(Buffer crlValue)
Add a CRL value -
Uses of Buffer in io.vertx.ext.mail
Methods in io.vertx.ext.mail that return Buffer Modifier and Type Method Description Buffer
MailAttachment. getData()
get the dataMethods in io.vertx.ext.mail that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
MailAttachment. getStream()
Gets the data stream.Methods in io.vertx.ext.mail with parameters of type Buffer Modifier and Type Method Description MailConfig
MailConfig. addCrlValue(Buffer crlValue)
MailAttachment
MailAttachment. setData(Buffer data)
set the dataMethod parameters in io.vertx.ext.mail with type arguments of type Buffer Modifier and Type Method Description MailAttachment
MailAttachment. setStream(ReadStream<Buffer> stream)
Sets the data stream. -
Uses of Buffer in io.vertx.ext.mail.mailencoder
Methods in io.vertx.ext.mail.mailencoder that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
EncodedPart. bodyStream(Context context)
ReadStream<Buffer>
EncodedPart. dkimBodyStream(Context context)
-
Uses of Buffer in io.vertx.ext.mongo
Methods in io.vertx.ext.mongo that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
MongoGridFsClient. readByFileName(String fileName)
Read file by name to ReadStreamReadStream<Buffer>
MongoGridFsClient. readByFileNameWithOptions(String fileName, GridFsDownloadOptions options)
Read file by name to ReadStream with optionsReadStream<Buffer>
MongoGridFsClient. readById(String id)
Read file by id to ReadStreamMethod parameters in io.vertx.ext.mongo with type arguments of type Buffer Modifier and Type Method Description Future<Long>
MongoGridFsClient. downloadByFileName(WriteStream<Buffer> stream, String fileName)
Future<Long>
MongoGridFsClient. downloadByFileNameWithOptions(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options)
Future<Long>
MongoGridFsClient. downloadById(WriteStream<Buffer> stream, String id)
Future<String>
MongoGridFsClient. uploadByFileName(ReadStream<Buffer> stream, String fileName)
Future<String>
MongoGridFsClient. uploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options)
-
Uses of Buffer in io.vertx.ext.shell.term
Methods in io.vertx.ext.shell.term that return Buffer Modifier and Type Method Description static Buffer
HttpTermOptions. defaultShellHtmlResource()
static Buffer
HttpTermOptions. defaultTermJsResource()
static Buffer
HttpTermOptions. defaultVertxShellJsResource()
Buffer
HttpTermOptions. getShellHtmlResource()
Buffer
HttpTermOptions. getTermJsResource()
Buffer
HttpTermOptions. getVertsShellJsResource()
Methods in io.vertx.ext.shell.term with parameters of type Buffer Modifier and Type Method Description HttpTermOptions
HttpTermOptions. addCrlValue(Buffer crlValue)
TelnetTermOptions
TelnetTermOptions. addCrlValue(Buffer crlValue)
HttpTermOptions
HttpTermOptions. setShellHtmlResource(Buffer shellHtmlResource)
Setshell.html
resource to use.HttpTermOptions
HttpTermOptions. setTermJsResource(Buffer termJsResource)
Setterm.js
resource to use.HttpTermOptions
HttpTermOptions. setVertsShellJsResource(Buffer vertsShellJsResource)
Setvertxshell.js
resource to use. -
Uses of Buffer in io.vertx.ext.stomp
Methods in io.vertx.ext.stomp that return Buffer Modifier and Type Method Description Buffer
Frame. getBody()
Buffer
Frame. toBuffer()
This method does not enforce the trailing line option.Buffer
Frame. toBuffer(boolean trailingLine)
Creates a buffer for the current frame.Methods in io.vertx.ext.stomp with parameters of type Buffer Modifier and Type Method Description Future<Frame>
StompClientConnection. send(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Future<Frame>
StompClientConnection. send(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Future<Frame>
StompClientConnection. send(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.Frame
Frame. setBody(Buffer body)
Sets the body of the frame.StompServerConnection
StompServerConnection. write(Buffer buffer)
Writes the given buffer to the socket.Constructors in io.vertx.ext.stomp with parameters of type Buffer Constructor Description Frame(Command command, Map<String,String> headers, Buffer body)
Creates a new instance ofFrame
. -
Uses of Buffer in io.vertx.ext.web
Methods in io.vertx.ext.web that return Buffer Modifier and Type Method Description Buffer
RequestBody. buffer()
Methods in io.vertx.ext.web with parameters of type Buffer Modifier and Type Method Description default Future<Void>
RoutingContext. end(Buffer buffer)
Shortcut to the response end. -
Uses of Buffer in io.vertx.ext.web.api.service
Methods in io.vertx.ext.web.api.service that return Buffer Modifier and Type Method Description Buffer
ServiceResponse. getPayload()
Methods in io.vertx.ext.web.api.service with parameters of type Buffer Modifier and Type Method Description static ServiceResponse
ServiceResponse. completedWithJson(Buffer json)
Creates aServiceResponse
with status code 200, status message OK, content typeapplication/json
andjson
as bodystatic ServiceResponse
ServiceResponse. completedWithPlainText(Buffer text)
Creates aServiceResponse
with status code 200, status message OK, content typetext/plain
andtext
as bodyServiceResponse
ServiceResponse. setPayload(Buffer payload)
Constructors in io.vertx.ext.web.api.service with parameters of type Buffer Constructor Description ServiceResponse(Integer statusCode, String statusMessage, Buffer payload, MultiMap headers)
-
Uses of Buffer in io.vertx.ext.web.client
Methods in io.vertx.ext.web.client that return Buffer Modifier and Type Method Description Buffer
HttpResponse. bodyAsBuffer()
Methods in io.vertx.ext.web.client that return types with arguments of type Buffer Modifier and Type Method Description default 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.default 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.default HttpRequest<Buffer>
WebClient. delete(UriTemplate requestURI)
Create an HTTP DELETE request to send to the server at the default host and port.default HttpRequest<Buffer>
WebClient. delete(String requestURI)
Create an HTTP DELETE request to send to the server at the default host and port.default 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.default 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.default 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 responsedefault 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 responsedefault 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.default 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.default HttpRequest<Buffer>
WebClient. get(UriTemplate requestURI)
Create an HTTP GET request to send to the server at the default host and port.default HttpRequest<Buffer>
WebClient. get(String requestURI)
Create an HTTP GET request to send to the server at the default host and port.default 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.default 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.default 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 responsedefault 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 responsedefault 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.default 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.default HttpRequest<Buffer>
WebClient. head(UriTemplate requestURI)
Create an HTTP HEAD request to send to the server at the default host and port.default HttpRequest<Buffer>
WebClient. head(String requestURI)
Create an HTTP HEAD request to send to the server at the default host and port.default 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.default 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.default 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 responsedefault 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 responsedefault 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.default 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.default HttpRequest<Buffer>
WebClient. patch(UriTemplate requestURI)
Create an HTTP PATCH request to send to the server at the default host and port.default HttpRequest<Buffer>
WebClient. patch(String requestURI)
Create an HTTP PATCH request to send to the server at the default host and port.default 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.default 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.default 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 responsedefault 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 responsedefault 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.default 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.default HttpRequest<Buffer>
WebClient. post(UriTemplate requestURI)
Create an HTTP POST request to send to the server at the default host and port.default HttpRequest<Buffer>
WebClient. post(String requestURI)
Create an HTTP POST request to send to the server at the default host and port.default 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.default 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.default 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 responsedefault 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 responsedefault 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.default 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.default HttpRequest<Buffer>
WebClient. put(UriTemplate requestURI)
Create an HTTP PUT request to send to the server at the default host and port.default HttpRequest<Buffer>
WebClient. put(String requestURI)
Create an HTTP PUT request to send to the server at the default host and port.default 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.default 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.default 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 responsedefault 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 responsedefault 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.default 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.default 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, UriTemplate requestURI)
LikeWebClient.request(HttpMethod, int, String, UriTemplate)
using theserverAddress
parameter to connect to the server instead of theport
andhost
parameters.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, int port, String host, String requestURI)
LikeWebClient.request(HttpMethod, int, String, String)
using theserverAddress
parameter to connect to the server instead of theport
andhost
parameters.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, RequestOptions options)
LikeWebClient.request(HttpMethod, RequestOptions)
using theserverAddress
parameter to connect to the server instead of theoptions
parameter.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, UriTemplate requestURI)
LikeWebClient.request(HttpMethod, UriTemplate)
using theserverAddress
parameter to connect to the server instead of the default port and default host.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String requestURI)
LikeWebClient.request(HttpMethod, String)
using theserverAddress
parameter to connect to the server instead of the default port and default host.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String host, UriTemplate requestURI)
LikeWebClient.request(HttpMethod, String, UriTemplate)
using theserverAddress
parameter to connect to the server instead of the default port andhost
parameter.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String host, String requestURI)
LikeWebClient.request(HttpMethod, String, String)
using theserverAddress
parameter to connect to the server instead of the default port andhost
parameter.default HttpRequest<Buffer>
WebClient. request(HttpMethod method, UriTemplate requestURI)
Create an HTTP request to send to the server at the default host and port.default HttpRequest<Buffer>
WebClient. request(HttpMethod method, String requestURI)
Create an HTTP request to send to the server at the default host and port.default 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.default 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, UriTemplate absoluteURI)
LikeWebClient.requestAbs(HttpMethod, UriTemplate)
using theserverAddress
parameter to connect to the server instead of theabsoluteURI
parameter.HttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, SocketAddress serverAddress, String absoluteURI)
LikeWebClient.requestAbs(HttpMethod, String)
using theserverAddress
parameter to connect to the server instead of theabsoluteURI
parameter.default HttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, UriTemplate absoluteURI)
Create an HTTP request to send to the server using an absolute URIdefault HttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, String absoluteURI)
Create an HTTP request to send to the server using an absolute URIMethods in io.vertx.ext.web.client with parameters of type Buffer Modifier and Type Method Description CachingWebClientOptions
CachingWebClientOptions. addCrlValue(Buffer crlValue)
WebClientOptions
WebClientOptions. addCrlValue(Buffer crlValue)
default HttpRequest<T>
HttpRequest. basicAuthentication(Buffer id, Buffer password)
Configure the request to perform basic access authentication.Future<HttpResponse<T>>
HttpRequest. sendBuffer(Buffer body)
LikeHttpRequest.send()
but with an HTTP requestbody
buffer.Method parameters in io.vertx.ext.web.client with type arguments of type Buffer Modifier and Type Method Description Future<HttpResponse<T>>
HttpRequest. sendStream(ReadStream<Buffer> body)
LikeHttpRequest.send()
but with an HTTP requestbody
stream. -
Uses of Buffer in io.vertx.ext.web.codec
Methods in io.vertx.ext.web.codec that return types with arguments of type Buffer Modifier and Type Method Description static BodyCodec<Buffer>
BodyCodec. buffer()
Method parameters in io.vertx.ext.web.codec with type arguments of type Buffer Modifier and Type Method 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 thedecode
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. -
Uses of Buffer in io.vertx.ext.web.common.template
Methods in io.vertx.ext.web.common.template that return types with arguments of type Buffer Modifier and Type Method Description default Future<Buffer>
TemplateEngine. render(JsonObject context, String templateFileName)
Render the template.Future<Buffer>
TemplateEngine. render(Map<String,Object> context, String templateFileName)
Render the template. -
Uses of Buffer in io.vertx.ext.web.handler.sockjs
Methods in io.vertx.ext.web.handler.sockjs with parameters of type Buffer Modifier and Type Method Description Future<Void>
SockJSSocket. write(Buffer data)
Method parameters in io.vertx.ext.web.handler.sockjs with type arguments of type Buffer Modifier and Type Method Description SockJSSocket
SockJSSocket. handler(Handler<Buffer> handler)
-
Uses of Buffer in io.vertx.ext.web.multipart
Methods in io.vertx.ext.web.multipart that return Buffer Modifier and Type Method Description Buffer
FormDataPart. content()
Methods in io.vertx.ext.web.multipart with parameters of type Buffer Modifier and Type Method 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. -
Uses of Buffer in io.vertx.ext.web.sstore
Methods in io.vertx.ext.web.sstore with parameters of type Buffer Modifier and Type Method Description protected int
AbstractSession. readDataFromBuffer(int pos, Buffer buffer)
protected void
AbstractSession. readDataFromBuffer(Buffer buffer)
protected void
AbstractSession. writeDataToBuffer(Buffer buffer)
-
Uses of Buffer in io.vertx.ext.web.sstore.cookie
Methods in io.vertx.ext.web.sstore.cookie with parameters of type Buffer Modifier and Type Method Description static CookieSessionStore
CookieSessionStore. create(Vertx vertx, String secret, Buffer salt)
Creates a CookieSessionStore. -
Uses of Buffer in io.vertx.ext.web.validation
Methods in io.vertx.ext.web.validation that return Buffer Modifier and Type Method Description Buffer
RequestParameter. getBuffer()
-
Uses of Buffer in io.vertx.grpc.client
Methods in io.vertx.grpc.client that return types with arguments of type Buffer Modifier and Type Method Description Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request()
LikeGrpcClient.request(Address)
with the default remote server.Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request()
LikeGrpcClient.request(Address)
with the default remote server.Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service. -
Uses of Buffer in io.vertx.grpc.common
Fields in io.vertx.grpc.common with type parameters of type Buffer Modifier and Type Field Description static GrpcMessageDecoder<Buffer>
GrpcMessageDecoder. IDENTITY
static GrpcMessageEncoder<Buffer>
GrpcMessageEncoder. IDENTITY
Methods in io.vertx.grpc.common that return Buffer Modifier and Type Method Description Buffer
GrpcMessage. payload()
Methods in io.vertx.grpc.common with parameters of type Buffer Modifier and Type Method Description static GrpcMessage
GrpcMessage. message(String encoding, Buffer payload)
static GrpcMessage
GrpcMessage. message(String encoding, WireFormat format, Buffer payload)
-
Uses of Buffer in io.vertx.grpc.server
Method parameters in io.vertx.grpc.server with type arguments of type Buffer Modifier and Type Method 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. -
Uses of Buffer in io.vertx.grpcio.server
Method parameters in io.vertx.grpcio.server with type arguments of type Buffer Modifier and Type Method Description GrpcIoServer
GrpcIoServer. callHandler(Handler<GrpcServerRequest<Buffer,Buffer>> handler)
GrpcIoServer
GrpcIoServer. callHandler(Handler<GrpcServerRequest<Buffer,Buffer>> handler)
-
Uses of Buffer in io.vertx.httpproxy
Methods in io.vertx.httpproxy that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
Body. stream()
Get stream of theBody
.Methods in io.vertx.httpproxy with parameters of type Buffer Modifier and Type Method Description static Body
Body. body(Buffer buffer)
Create a newBody
instance.Method parameters in io.vertx.httpproxy with type arguments of type Buffer Modifier and Type Method Description static Body
Body. body(ReadStream<Buffer> stream)
Create a newBody
instance.static Body
Body. body(ReadStream<Buffer> stream, long len)
Create a newBody
instance. -
Uses of Buffer in io.vertx.jdbcclient.spi
Methods in io.vertx.jdbcclient.spi that return Buffer Modifier and Type Method Description protected Buffer
JDBCDecoderImpl. streamToBuffer(InputStream is, Class<?> dataTypeClass)
-
Uses of Buffer in io.vertx.kafka.client.producer
Methods in io.vertx.kafka.client.producer that return Buffer Modifier and Type Method Description Buffer
KafkaHeader. value()
Methods in io.vertx.kafka.client.producer with parameters of type Buffer Modifier and Type Method Description KafkaProducerRecord<K,V>
KafkaProducerRecord. addHeader(String key, Buffer value)
LikeKafkaProducerRecord.addHeader(KafkaHeader)
but with a key/value pairstatic KafkaHeader
KafkaHeader. header(String key, Buffer value)
-
Uses of Buffer in io.vertx.kafka.client.serialization
Methods in io.vertx.kafka.client.serialization that return Buffer Modifier and Type Method Description Buffer
BufferDeserializer. deserialize(String topic, byte[] data)
Methods in io.vertx.kafka.client.serialization that return types with arguments of type Buffer Modifier and Type Method Description static org.apache.kafka.common.serialization.Serde<Buffer>
VertxSerdes. Buffer()
Methods in io.vertx.kafka.client.serialization with parameters of type Buffer Modifier and Type Method Description byte[]
BufferSerializer. serialize(String topic, Buffer data)
-
Uses of Buffer in io.vertx.mqtt
Methods in io.vertx.mqtt that return Buffer Modifier and Type Method Description Buffer
MqttWill. getWillMessage()
Buffer
MqttClientOptions. getWillMessageBytes()
Methods in io.vertx.mqtt with parameters of type Buffer Modifier and Type Method Description MqttClientOptions
MqttClientOptions. addCrlValue(Buffer crlValue)
MqttServerOptions
MqttServerOptions. addCrlValue(Buffer crlValue)
Future<Integer>
MqttClient. publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT serverFuture<Integer>
MqttEndpoint. publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT clientFuture<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 messageIdFuture<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 messageIdMqttClientOptions
MqttClientOptions. setWillMessageBytes(Buffer willMessage)
Set the content of the will messageConstructors in io.vertx.mqtt with parameters of type Buffer Constructor Description MqttWill(boolean isWillFlag, String willTopic, Buffer willMessage, int willQos, boolean isWillRetain, MqttProperties willProperties)
Constructor -
Uses of Buffer in io.vertx.mqtt.messages
Methods in io.vertx.mqtt.messages that return Buffer Modifier and Type Method Description Buffer
MqttAuthenticationExchangeMessage. authenticationData()
Buffer
MqttPublishMessage. payload()
Methods in io.vertx.mqtt.messages with parameters of type Buffer Modifier and Type Method Description static MqttPublishMessage
MqttPublishMessage. create(int messageId, MqttQoS qosLevel, boolean isDup, boolean isRetain, String topicName, Buffer payload)
Create a concrete instance of a Vert.x publish messagestatic MqttPublishMessage
MqttPublishMessage. create(int messageId, MqttQoS qosLevel, boolean isDup, boolean isRetain, String topicName, Buffer payload, MqttProperties properties)
Create a concrete instance of a Vert.x publish message -
Uses of Buffer in io.vertx.mysqlclient
Methods in io.vertx.mysqlclient that return Buffer Modifier and Type Method Description Buffer
MySQLAuthOptions. getServerRsaPublicKeyValue()
Get the value of the server RSA public key.Buffer
MySQLConnectOptions. getServerRsaPublicKeyValue()
Get the value of the server RSA public key.Methods in io.vertx.mysqlclient with parameters of type Buffer Modifier and Type Method Description MySQLAuthOptions
MySQLAuthOptions. setServerRsaPublicKeyValue(Buffer serverRsaPublicKeyValue)
Set the value of server RSA public key which is mostly used for encrypting password under insecure connections when performing authentication.MySQLConnectOptions
MySQLConnectOptions. setServerRsaPublicKeyValue(Buffer serverRsaPublicKeyValue)
Set the value of server RSA public key which is mostly used for encrypting password under insecure connections when performing authentication. -
Uses of Buffer in io.vertx.openapi.validation
Methods in io.vertx.openapi.validation that return Buffer Modifier and Type Method Description default Buffer
Parameter. getBuffer()
default Buffer
Parameter. getBuffer(Buffer defaultValue)
Methods in io.vertx.openapi.validation with parameters of type Buffer Modifier and Type Method Description static ValidatableResponse
ValidatableResponse. create(int statusCode, Buffer body, String contentType)
Creates a newValidatableResponse
object based on the passed parameters.static ValidatableResponse
ValidatableResponse. create(int statusCode, Map<String,String> headers, Buffer body, String contentType)
Creates a newValidatableResponse
object based on the passed parameters.default Buffer
Parameter. getBuffer(Buffer defaultValue)
Method parameters in io.vertx.openapi.validation with type arguments of type Buffer Modifier and Type Method Description static Future<ValidatableRequest>
RequestUtils. extract(HttpServerRequest request, Operation operation, java.util.function.Supplier<Future<Buffer>> bodySupplier)
LikeRequestUtils.extract(HttpServerRequest, Operation)
, but offers to pass a supplier fpr the body. -
Uses of Buffer in io.vertx.openapi.validation.analyser
Fields in io.vertx.openapi.validation.analyser declared as Buffer Modifier and Type Field Description protected Buffer
ContentAnalyser. content
Methods in io.vertx.openapi.validation.analyser that return Buffer Modifier and Type Method Description Buffer
MultipartPart. getBody()
Methods in io.vertx.openapi.validation.analyser with parameters of type Buffer Modifier and Type Method Description protected static Object
ContentAnalyser. decodeJsonContent(Buffer content, ValidationContext requestOrResponse)
Decodes the passed content as JSON.static ContentAnalyser
ContentAnalyser. getContentAnalyser(MediaType mediaType, String contentType, Buffer content, ValidationContext context)
Returns the content analyser for the given content type.Constructors in io.vertx.openapi.validation.analyser with parameters of type Buffer Constructor Description ApplicationJsonAnalyser(String contentType, Buffer content, ValidationContext context)
ContentAnalyser(String contentType, Buffer content, ValidationContext context)
Creates a new content analyser.MultipartFormAnalyser(String contentType, Buffer content, ValidationContext context)
Creates a new content analyser.MultipartPart(String name, String contentType, Buffer body)
-
Uses of Buffer in io.vertx.oracleclient.data
Methods in io.vertx.oracleclient.data with parameters of type Buffer Modifier and Type Method Description static Blob
Blob. copy(Buffer buffer)
-
Uses of Buffer in io.vertx.rabbitmq
Methods in io.vertx.rabbitmq that return Buffer Modifier and Type Method Description Buffer
RabbitMQMessage. body()
Methods in io.vertx.rabbitmq with parameters of type Buffer Modifier and Type Method Description Future<Void>
RabbitMQClient. basicPublish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
Publish a message.Future<Void>
RabbitMQClient. basicPublish(String exchange, String routingKey, Buffer body)
Publish a message.Future<Void>
RabbitMQClient. basicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler)
Publish a message.Future<Void>
RabbitMQPublisher. publish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
Publish a message.Future<Long>
RabbitMQPublisher. publishConfirm(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
Publish a message and complete when publish confirm has returned. -
Uses of Buffer in io.vertx.reactivex
Methods in io.vertx.reactivex that return types with arguments of type Buffer Modifier and Type Method Description static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(Class<T> mappedType)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(Class<T> mappedType)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(Class<T> mappedType)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(Class<T> mappedType)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
-
Uses of Buffer in io.vertx.reactivex.amqp
Methods in io.vertx.reactivex.amqp that return Buffer Modifier and Type Method Description Buffer
AmqpMessage. bodyAsBinary()
Methods in io.vertx.reactivex.amqp with parameters of type Buffer Modifier and Type Method Description AmqpMessageBuilder
AmqpMessageBuilder. withBufferAsBody(Buffer buffer)
-
Uses of Buffer in io.vertx.reactivex.core
Methods in io.vertx.reactivex.core that return types with arguments of type Buffer Modifier and Type Method Description static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(Class<T> mappedType)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(Class<T> mappedType)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(Class<T> mappedType)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(Class<T> mappedType)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
-
Uses of Buffer in io.vertx.reactivex.core.datagram
Methods in io.vertx.reactivex.core.datagram that return types with arguments of type Buffer Modifier and Type Method Description WriteStream<Buffer>
DatagramSocket. sender(int port, String host)
Returns aWriteStream
able to send to theSocketAddress
.Methods in io.vertx.reactivex.core.datagram with parameters of type Buffer Modifier and Type Method Description Completable
DatagramSocket. rxSend(Buffer packet, int port, String host)
Write the givenBuffer
to theSocketAddress
.Future<Void>
DatagramSocket. send(Buffer packet, int port, String host)
Write the givenBuffer
to theSocketAddress
. -
Uses of Buffer in io.vertx.reactivex.core.file
Methods in io.vertx.reactivex.core.file that return Buffer Modifier and Type Method Description Buffer
FileSystem. readFileBlocking(String path)
Blocking version ofFileSystem.readFile(java.lang.String)
Methods in io.vertx.reactivex.core.file that return types with arguments of type Buffer Modifier and Type Method Description Pipe<Buffer>
AsyncFile. pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .Future<Buffer>
AsyncFile. read(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Future<Buffer>
FileSystem. readFile(String path)
Reads the entire file as represented by the pathpath
as a , asynchronously.Single<Buffer>
AsyncFile. rxRead(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Single<Buffer>
FileSystem. rxReadFile(String path)
Reads the entire file as represented by the pathpath
as a , asynchronously.Flowable<Buffer>
AsyncFile. toFlowable()
Observable<Buffer>
AsyncFile. toObservable()
WriteStreamObserver<Buffer>
AsyncFile. toObserver()
WriteStreamSubscriber<Buffer>
AsyncFile. toSubscriber()
Methods in io.vertx.reactivex.core.file with parameters of type Buffer Modifier and Type Method Description Future<Void>
AsyncFile. end(Buffer data)
Same asWriteStream.end()
but writes some data to the stream before ending.Future<Buffer>
AsyncFile. read(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Completable
AsyncFile. rxEnd(Buffer data)
Same asWriteStream.end()
but writes some data to the stream before ending.Single<Buffer>
AsyncFile. rxRead(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Completable
AsyncFile. rxWrite(Buffer data)
Write some data to the stream.Completable
AsyncFile. rxWrite(Buffer buffer, long position)
Write aBuffer
to the file at positionposition
in the file, asynchronously.Completable
FileSystem. rxWriteFile(String path, Buffer data)
Creates the file, and writes the specifiedBuffer data
to the file represented by the pathpath
, asynchronously.Future<Void>
AsyncFile. write(Buffer data)
Write some data to the stream.Future<Void>
AsyncFile. write(Buffer buffer, long position)
Write aBuffer
to the file at positionposition
in the file, asynchronously.Future<Void>
FileSystem. writeFile(String path, Buffer data)
Creates the file, and writes the specifiedBuffer data
to the file represented by the pathpath
, asynchronously.FileSystem
FileSystem. writeFileBlocking(String path, Buffer data)
Blocking version ofFileSystem.writeFile(java.lang.String, io.vertx.core.buffer.Buffer)
Method parameters in io.vertx.reactivex.core.file with type arguments of type Buffer Modifier and Type Method Description AsyncFile
AsyncFile. handler(Handler<Buffer> handler)
Future<Void>
AsyncFile. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
AsyncFile. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
. -
Uses of Buffer in io.vertx.reactivex.core.http
Methods in io.vertx.reactivex.core.http that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
HttpClientResponse. body()
Convenience method for receiving the entire request body in one piece.Future<Buffer>
HttpServerRequest. body()
Convenience method for receiving the entire request body in one piece.Future<Buffer>
HttpConnection. ping(Buffer data)
Send a frame to the remote endpoint.Pipe<Buffer>
ClientWebSocket. pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .Pipe<Buffer>
HttpClientResponse. 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>
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>
WebSocketBase. pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .Single<Buffer>
HttpClientResponse. rxBody()
Convenience method for receiving the entire request body in one piece.Single<Buffer>
HttpServerRequest. rxBody()
Convenience method for receiving the entire request body in one piece.Single<Buffer>
HttpConnection. rxPing(Buffer data)
Send a frame to the remote endpoint.Flowable<Buffer>
ClientWebSocket. toFlowable()
Flowable<Buffer>
HttpClientResponse. toFlowable()
Flowable<Buffer>
HttpServerFileUpload. toFlowable()
Flowable<Buffer>
HttpServerRequest. toFlowable()
Flowable<Buffer>
ServerWebSocket. toFlowable()
Flowable<Buffer>
WebSocket. toFlowable()
Observable<Buffer>
ClientWebSocket. toObservable()
Observable<Buffer>
HttpClientResponse. toObservable()
Observable<Buffer>
HttpServerFileUpload. toObservable()
Observable<Buffer>
HttpServerRequest. toObservable()
Observable<Buffer>
ServerWebSocket. toObservable()
Observable<Buffer>
WebSocket. toObservable()
WriteStreamObserver<Buffer>
ClientWebSocket. toObserver()
WriteStreamObserver<Buffer>
HttpClientRequest. toObserver()
WriteStreamObserver<Buffer>
HttpServerResponse. toObserver()
WriteStreamObserver<Buffer>
ServerWebSocket. toObserver()
WriteStreamObserver<Buffer>
WebSocket. toObserver()
WriteStreamSubscriber<Buffer>
ClientWebSocket. toSubscriber()
WriteStreamSubscriber<Buffer>
HttpClientRequest. toSubscriber()
WriteStreamSubscriber<Buffer>
HttpServerResponse. toSubscriber()
WriteStreamSubscriber<Buffer>
ServerWebSocket. toSubscriber()
WriteStreamSubscriber<Buffer>
WebSocket. toSubscriber()
Methods in io.vertx.reactivex.core.http with parameters of type Buffer Modifier and Type Method Description Future<Void>
ClientWebSocket. end(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Future<Void>
HttpClientRequest. end(Buffer chunk)
Same asHttpClientRequest.end(java.lang.String)
but writes some data to the request body before ending.Future<Void>
HttpServerResponse. end(Buffer chunk)
Same asHttpServerResponse.end(java.lang.String)
but writes some data to the response body before ending.Future<Void>
ServerWebSocket. end(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Future<Void>
WebSocket. end(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Future<Void>
WebSocketBase. end(Buffer data)
Same asWebSocketBase.end(io.vertx.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.Future<Buffer>
HttpConnection. ping(Buffer data)
Send a frame to the remote endpoint.Completable
ClientWebSocket. rxEnd(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
HttpClientRequest. rxEnd(Buffer chunk)
Same asHttpClientRequest.end(java.lang.String)
but writes some data to the request body before ending.Completable
HttpServerResponse. rxEnd(Buffer chunk)
Same asHttpServerResponse.end(java.lang.String)
but writes some data to the response body before ending.Completable
ServerWebSocket. rxEnd(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
WebSocket. rxEnd(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
WebSocketBase. rxEnd(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Single<Buffer>
HttpConnection. rxPing(Buffer data)
Send a frame to the remote endpoint.Single<HttpClientResponse>
HttpClientRequest. rxSend(Buffer body)
Send the request with a bufferbody
.Completable
HttpServerResponse. rxSend(Buffer body)
Send the request with a bufferbody
.Completable
ClientWebSocket. rxWrite(Buffer data)
Write some data to the stream.Completable
HttpClientRequest. rxWrite(Buffer data)
Write some data to the stream.Completable
HttpServerResponse. rxWrite(Buffer data)
Write some data to the stream.Completable
ServerWebSocket. rxWrite(Buffer data)
Write some data to the stream.Completable
WebSocket. rxWrite(Buffer data)
Write some data to the stream.Completable
WebSocketBase. rxWrite(Buffer data)
Write some data to the stream.Completable
ClientWebSocket. rxWriteBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
ServerWebSocket. rxWriteBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
WebSocket. rxWriteBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
WebSocketBase. rxWriteBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
HttpClientRequest. rxWriteCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.Completable
HttpServerResponse. rxWriteCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.Completable
ClientWebSocket. rxWriteFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
ServerWebSocket. rxWriteFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
WebSocket. rxWriteFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
WebSocketBase. rxWriteFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
ClientWebSocket. rxWritePing(Buffer data)
Writes a ping frame to the connection.Completable
ServerWebSocket. rxWritePing(Buffer data)
Writes a ping frame to the connection.Completable
WebSocket. rxWritePing(Buffer data)
Writes a ping frame to the connection.Completable
WebSocketBase. rxWritePing(Buffer data)
Writes a ping frame to the connection.Completable
ClientWebSocket. rxWritePong(Buffer data)
Writes a pong frame to the connection.Completable
ServerWebSocket. rxWritePong(Buffer data)
Writes a pong frame to the connection.Completable
WebSocket. rxWritePong(Buffer data)
Writes a pong frame to the connection.Completable
WebSocketBase. rxWritePong(Buffer data)
Writes a pong frame to the connection.Future<HttpClientResponse>
HttpClientRequest. send(Buffer body)
Send the request with a bufferbody
.Future<Void>
HttpServerResponse. send(Buffer body)
Send the request with a bufferbody
.Future<Void>
ClientWebSocket. write(Buffer data)
Write some data to the stream.Future<Void>
HttpClientRequest. write(Buffer data)
Write some data to the stream.Future<Void>
HttpServerResponse. write(Buffer data)
Write some data to the stream.Future<Void>
ServerWebSocket. write(Buffer data)
Write some data to the stream.Future<Void>
WebSocket. write(Buffer data)
Write some data to the stream.Future<Void>
WebSocketBase. write(Buffer data)
Write some data to the stream.Future<Void>
ClientWebSocket. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Future<Void>
ServerWebSocket. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Future<Void>
WebSocket. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Future<Void>
WebSocketBase. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Future<Void>
HttpClientRequest. writeCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.Future<Void>
HttpServerResponse. writeCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.Future<Void>
ClientWebSocket. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionFuture<Void>
ServerWebSocket. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionFuture<Void>
WebSocket. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionFuture<Void>
WebSocketBase. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionFuture<Void>
ClientWebSocket. writePing(Buffer data)
Writes a ping frame to the connection.Future<Void>
ServerWebSocket. writePing(Buffer data)
Writes a ping frame to the connection.Future<Void>
WebSocket. writePing(Buffer data)
Writes a ping frame to the connection.Future<Void>
WebSocketBase. writePing(Buffer data)
Writes a ping frame to the connection.Future<Void>
ClientWebSocket. writePong(Buffer data)
Writes a pong frame to the connection.Future<Void>
ServerWebSocket. writePong(Buffer data)
Writes a pong frame to the connection.Future<Void>
WebSocket. writePong(Buffer data)
Writes a pong frame to the connection.Future<Void>
WebSocketBase. writePong(Buffer data)
Writes a pong frame to the connection.Method parameters in io.vertx.reactivex.core.http with type arguments of type Buffer Modifier and Type Method Description ClientWebSocket
ClientWebSocket. binaryMessageHandler(Handler<Buffer> handler)
WebSocket
WebSocket. binaryMessageHandler(Handler<Buffer> handler)
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.ClientWebSocket
ClientWebSocket. handler(Handler<Buffer> handler)
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. pingHandler(Handler<Buffer> handler)
Set an handler notified when a frame is received from the remote endpoint.Future<Void>
ClientWebSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Future<Void>
HttpClientResponse. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Future<Void>
HttpServerFileUpload. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Future<Void>
HttpServerRequest. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Future<Void>
ServerWebSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Future<Void>
WebSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Future<Void>
WebSocketBase. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.ClientWebSocket
ClientWebSocket. pongHandler(Handler<Buffer> handler)
WebSocket
WebSocket. pongHandler(Handler<Buffer> handler)
WebSocketBase
WebSocketBase. pongHandler(Handler<Buffer> handler)
Set a pong frame handler on the connection.Completable
ClientWebSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpClientResponse. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpServerFileUpload. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpServerRequest. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
ServerWebSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
WebSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
WebSocketBase. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Single<HttpClientResponse>
HttpClientRequest. rxSend(Flowable<Buffer> body)
Send the request with a streambody
.Single<HttpClientResponse>
HttpClientRequest. rxSend(ReadStream<Buffer> body)
Send the request with a streambody
.Completable
HttpServerResponse. rxSend(Flowable<Buffer> body)
Send the request with a streambody
.Completable
HttpServerResponse. rxSend(ReadStream<Buffer> body)
Send the request with a streambody
.Future<HttpClientResponse>
HttpClientRequest. send(Flowable<Buffer> body)
Send the request with a streambody
.Future<HttpClientResponse>
HttpClientRequest. send(ReadStream<Buffer> body)
Send the request with a streambody
.Future<Void>
HttpServerResponse. send(Flowable<Buffer> body)
Send the request with a streambody
.Future<Void>
HttpServerResponse. send(ReadStream<Buffer> body)
Send the request with a streambody
. -
Uses of Buffer in io.vertx.reactivex.core.net
Methods in io.vertx.reactivex.core.net that return types with arguments of type Buffer Modifier and Type Method 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()
Methods in io.vertx.reactivex.core.net with parameters of type Buffer Modifier and Type Method Description Future<Void>
NetSocket. end(Buffer data)
Same asNetSocket.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
NetSocket. rxEnd(Buffer data)
Same asNetSocket.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
NetSocket. rxUpgradeToSsl(Buffer msg)
LikeNetSocket.upgradeToSsl()
with the default SSL options and without indicating a server name.Completable
NetSocket. rxUpgradeToSsl(SSLOptions sslOptions, Buffer msg)
LikeNetSocket.upgradeToSsl()
without indicating a server nameCompletable
NetSocket. rxUpgradeToSsl(SSLOptions sslOptions, String serverName, Buffer upgrade)
Upgrade the channel to use SSL/TLS, in other words proceeds to the TLS handshake.Completable
NetSocket. rxUpgradeToSsl(String serverName, Buffer msg)
LikeNetSocket.upgradeToSsl()
with the default SSL options.Completable
NetSocket. rxWrite(Buffer data)
Write some data to the stream.Future<Void>
NetSocket. upgradeToSsl(Buffer msg)
LikeNetSocket.upgradeToSsl()
with the default SSL options and without indicating a server name.Future<Void>
NetSocket. upgradeToSsl(SSLOptions sslOptions, Buffer msg)
LikeNetSocket.upgradeToSsl()
without indicating a server nameFuture<Void>
NetSocket. upgradeToSsl(SSLOptions sslOptions, String serverName, Buffer upgrade)
Upgrade the channel to use SSL/TLS, in other words proceeds to the TLS handshake.Future<Void>
NetSocket. upgradeToSsl(String serverName, Buffer msg)
LikeNetSocket.upgradeToSsl()
with the default SSL options.Future<Void>
NetSocket. write(Buffer data)
Write some data to the stream.Method parameters in io.vertx.reactivex.core.net with type arguments of type Buffer Modifier and Type Method Description NetSocket
NetSocket. handler(Handler<Buffer> handler)
Future<Void>
NetSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
NetSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
. -
Uses of Buffer in io.vertx.reactivex.core.parsetools
Methods in io.vertx.reactivex.core.parsetools that return types with arguments of type Buffer Modifier and Type Method 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()
Methods in io.vertx.reactivex.core.parsetools with parameters of type Buffer Modifier and Type Method Description void
RecordParser. delimitedMode(Buffer delim)
Flip the parser into delimited mode, and where the delimiter can be represented by the delimiterdelim
.void
JsonParser. handle(Buffer event)
Something has happened, so handle it.void
RecordParser. handle(Buffer buffer)
This method is called to provide the parser with data.static RecordParser
RecordParser. newDelimited(Buffer delim)
Create a newRecordParser
instance, initially in delimited mode, and where the delimiter can be represented by theBuffer
delim.static RecordParser
RecordParser. newDelimited(Buffer delim, Flowable<Buffer> stream)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but wraps thestream
.static RecordParser
RecordParser. newDelimited(Buffer delim, Handler<Buffer> output)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but set theoutput
that will receive whole records which have been parsed.static RecordParser
RecordParser. newDelimited(Buffer delim, ReadStream<Buffer> stream)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but wraps thestream
.JsonParser
JsonParser. write(Buffer buffer)
Handle aBuffer
, pretty much like callingHandler
. -
Uses of Buffer in io.vertx.reactivex.ext.mail
Methods in io.vertx.reactivex.ext.mail that return Buffer Modifier and Type Method Description Buffer
MailAttachment. getData()
get the dataMethods in io.vertx.reactivex.ext.mail that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
MailAttachment. getStream()
Gets the data stream.Methods in io.vertx.reactivex.ext.mail with parameters of type Buffer Modifier and Type Method Description MailAttachment
MailAttachment. setData(Buffer data)
set the dataMethod parameters in io.vertx.reactivex.ext.mail with type arguments of type Buffer Modifier and Type Method Description MailAttachment
MailAttachment. setStream(Flowable<Buffer> stream)
Sets the data stream.MailAttachment
MailAttachment. setStream(ReadStream<Buffer> stream)
Sets the data stream. -
Uses of Buffer in io.vertx.reactivex.ext.mongo
Methods in io.vertx.reactivex.ext.mongo that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
MongoGridFsClient. readByFileName(String fileName)
Read file by name to ReadStreamReadStream<Buffer>
MongoGridFsClient. readByFileNameWithOptions(String fileName, GridFsDownloadOptions options)
Read file by name to ReadStream with optionsReadStream<Buffer>
MongoGridFsClient. readById(String id)
Read file by id to ReadStream -
Uses of Buffer in io.vertx.reactivex.ext.stomp
Methods in io.vertx.reactivex.ext.stomp with parameters of type Buffer Modifier and Type Method Description Single<Frame>
StompClientConnection. rxSend(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. rxSend(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. rxSend(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.Future<Frame>
StompClientConnection. send(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Future<Frame>
StompClientConnection. send(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Future<Frame>
StompClientConnection. send(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.StompServerConnection
StompServerConnection. write(Buffer buffer)
Writes the given buffer to the socket. -
Uses of Buffer in io.vertx.reactivex.ext.web
Methods in io.vertx.reactivex.ext.web that return Buffer Modifier and Type Method Description Buffer
RequestBody. buffer()
Methods in io.vertx.reactivex.ext.web with parameters of type Buffer Modifier and Type Method Description Future<Void>
RoutingContext. end(Buffer buffer)
Shortcut to the response end.Completable
RoutingContext. rxEnd(Buffer buffer)
Shortcut to the response end. -
Uses of Buffer in io.vertx.reactivex.ext.web.client
Methods in io.vertx.reactivex.ext.web.client that return Buffer Modifier and Type Method Description Buffer
HttpResponse. bodyAsBuffer()
Methods in io.vertx.reactivex.ext.web.client that return types with arguments of type Buffer Modifier and Type Method Description 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(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(UriTemplate requestURI)
Create an HTTP DELETE request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP DELETE request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP DELETE request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP GET request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP GET request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP GET request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP HEAD request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP HEAD request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP HEAD request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP PATCH request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP PATCH request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP PATCH request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP POST request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP POST request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP POST request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP PUT request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP PUT request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP PUT request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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, 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, UriTemplate requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theport
andhost
parameters.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, int port, String host, String requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theport
andhost
parameters.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, RequestOptions options)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theoptions
parameter.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, UriTemplate requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of the default port and default host.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of the default port and default host.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String host, UriTemplate requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of the default port andhost
parameter.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String host, String requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of the default port andhost
parameter.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. 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, UriTemplate 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, 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, UriTemplate absoluteURI)
LikeWebClient.requestAbs(io.vertx.core.http.HttpMethod, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theabsoluteURI
parameter.HttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, SocketAddress serverAddress, String absoluteURI)
LikeWebClient.requestAbs(io.vertx.core.http.HttpMethod, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theabsoluteURI
parameter.HttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, UriTemplate absoluteURI)
Create an HTTP request to send to the server using an absolute URIHttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, String absoluteURI)
Create an HTTP request to send to the server using an absolute URIMethods in io.vertx.reactivex.ext.web.client with parameters of type Buffer Modifier and Type Method Description HttpRequest<T>
HttpRequest. basicAuthentication(Buffer id, Buffer password)
Configure the request to perform basic access authentication.Single<HttpResponse<T>>
HttpRequest. rxSendBuffer(Buffer body)
LikeHttpRequest.send()
but with an HTTP requestbody
buffer.Future<HttpResponse<T>>
HttpRequest. sendBuffer(Buffer body)
LikeHttpRequest.send()
but with an HTTP requestbody
buffer.Method parameters in io.vertx.reactivex.ext.web.client with type arguments of type Buffer Modifier and Type Method Description Single<HttpResponse<T>>
HttpRequest. rxSendStream(Flowable<Buffer> body)
LikeHttpRequest.send()
but with an HTTP requestbody
stream.Single<HttpResponse<T>>
HttpRequest. rxSendStream(ReadStream<Buffer> body)
LikeHttpRequest.send()
but with an HTTP requestbody
stream.Future<HttpResponse<T>>
HttpRequest. sendStream(Flowable<Buffer> body)
LikeHttpRequest.send()
but with an HTTP requestbody
stream.Future<HttpResponse<T>>
HttpRequest. sendStream(ReadStream<Buffer> body)
LikeHttpRequest.send()
but with an HTTP requestbody
stream. -
Uses of Buffer in io.vertx.reactivex.ext.web.codec
Methods in io.vertx.reactivex.ext.web.codec that return types with arguments of type Buffer Modifier and Type Method Description static BodyCodec<Buffer>
BodyCodec. buffer()
Method parameters in io.vertx.reactivex.ext.web.codec with type arguments of type Buffer Modifier and Type Method 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 thedecode
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. -
Uses of Buffer in io.vertx.reactivex.ext.web.common.template
Methods in io.vertx.reactivex.ext.web.common.template that return types with arguments of type Buffer Modifier and Type Method Description Future<Buffer>
TemplateEngine. render(JsonObject context, String templateFileName)
Render the template.Future<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. -
Uses of Buffer in io.vertx.reactivex.ext.web.handler.sockjs
Methods in io.vertx.reactivex.ext.web.handler.sockjs that return types with arguments of type Buffer Modifier and Type Method 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()
Methods in io.vertx.reactivex.ext.web.handler.sockjs with parameters of type Buffer Modifier and Type Method Description Future<Void>
SockJSSocket. end(Buffer data)
Same asSockJSSocket.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
SockJSSocket. rxEnd(Buffer data)
Same asSockJSSocket.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
SockJSSocket. rxWrite(Buffer data)
Future<Void>
SockJSSocket. write(Buffer data)
Method parameters in io.vertx.reactivex.ext.web.handler.sockjs with type arguments of type Buffer Modifier and Type Method Description SockJSSocket
SockJSSocket. handler(Handler<Buffer> handler)
Future<Void>
SockJSSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
SockJSSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
. -
Uses of Buffer in io.vertx.reactivex.ext.web.multipart
Methods in io.vertx.reactivex.ext.web.multipart that return Buffer Modifier and Type Method Description Buffer
FormDataPart. content()
Methods in io.vertx.reactivex.ext.web.multipart with parameters of type Buffer Modifier and Type Method 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. -
Uses of Buffer in io.vertx.reactivex.ext.web.sstore.cookie
Methods in io.vertx.reactivex.ext.web.sstore.cookie with parameters of type Buffer Modifier and Type Method Description static CookieSessionStore
CookieSessionStore. create(Vertx vertx, String secret, Buffer salt)
Creates a CookieSessionStore. -
Uses of Buffer in io.vertx.reactivex.ext.web.validation
Methods in io.vertx.reactivex.ext.web.validation that return Buffer Modifier and Type Method Description Buffer
RequestParameter. getBuffer()
-
Uses of Buffer in io.vertx.reactivex.grpc.client
Methods in io.vertx.reactivex.grpc.client that return types with arguments of type Buffer Modifier and Type Method Description Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service. -
Uses of Buffer in io.vertx.reactivex.grpc.common
Fields in io.vertx.reactivex.grpc.common with type parameters of type Buffer Modifier and Type Field Description static GrpcMessageDecoder<Buffer>
GrpcMessageDecoder. IDENTITY
static GrpcMessageEncoder<Buffer>
GrpcMessageEncoder. IDENTITY
Methods in io.vertx.reactivex.grpc.common that return Buffer Modifier and Type Method Description Buffer
GrpcMessage. payload()
Methods in io.vertx.reactivex.grpc.common with parameters of type Buffer Modifier and Type Method Description static GrpcMessage
GrpcMessage. message(String encoding, Buffer payload)
static GrpcMessage
GrpcMessage. message(String encoding, WireFormat format, Buffer payload)
-
Uses of Buffer in io.vertx.reactivex.grpc.server
Method parameters in io.vertx.reactivex.grpc.server with type arguments of type Buffer Modifier and Type Method 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. -
Uses of Buffer in io.vertx.reactivex.kafka.client.producer
Methods in io.vertx.reactivex.kafka.client.producer that return Buffer Modifier and Type Method Description Buffer
KafkaHeader. value()
Methods in io.vertx.reactivex.kafka.client.producer with parameters of type Buffer Modifier and Type Method Description KafkaProducerRecord<K,V>
KafkaProducerRecord. addHeader(String key, Buffer value)
LikeKafkaProducerRecord.addHeader(java.lang.String, java.lang.String)
but with a key/value pairstatic KafkaHeader
KafkaHeader. header(String key, Buffer value)
-
Uses of Buffer in io.vertx.reactivex.mqtt
Methods in io.vertx.reactivex.mqtt with parameters of type Buffer Modifier and Type Method Description Future<Integer>
MqttClient. publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT serverFuture<Integer>
MqttEndpoint. publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT clientFuture<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 messageIdFuture<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 messageIdSingle<Integer>
MqttClient. rxPublish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT serverSingle<Integer>
MqttEndpoint. rxPublish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT clientSingle<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 messageIdSingle<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 -
Uses of Buffer in io.vertx.reactivex.mqtt.messages
Methods in io.vertx.reactivex.mqtt.messages that return Buffer Modifier and Type Method Description Buffer
MqttAuthenticationExchangeMessage. authenticationData()
Buffer
MqttPublishMessage. payload()
Methods in io.vertx.reactivex.mqtt.messages with parameters of type Buffer Modifier and Type Method Description static MqttPublishMessage
MqttPublishMessage. create(int messageId, MqttQoS qosLevel, boolean isDup, boolean isRetain, String topicName, Buffer payload, MqttProperties properties)
Create a concrete instance of a Vert.x publish message -
Uses of Buffer in io.vertx.reactivex.openapi.validation
Methods in io.vertx.reactivex.openapi.validation with parameters of type Buffer Modifier and Type Method Description static ValidatableResponse
ValidatableResponse. create(int statusCode, Buffer body, String contentType)
Creates a newValidatableResponse
object based on the passed parameters.static ValidatableResponse
ValidatableResponse. create(int statusCode, Map<String,String> headers, Buffer body, String contentType)
Creates a newValidatableResponse
object based on the passed parameters. -
Uses of Buffer in io.vertx.reactivex.rabbitmq
Methods in io.vertx.reactivex.rabbitmq that return Buffer Modifier and Type Method Description Buffer
RabbitMQMessage. body()
Methods in io.vertx.reactivex.rabbitmq with parameters of type Buffer Modifier and Type Method Description Future<Void>
RabbitMQClient. basicPublish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
Publish a message.Future<Void>
RabbitMQClient. basicPublish(String exchange, String routingKey, Buffer body)
Publish a message.Future<Void>
RabbitMQClient. basicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler)
Publish a message.Future<Void>
RabbitMQPublisher. publish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
Publish a message.Future<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. -
Uses of Buffer in io.vertx.reactivex.sqlclient
Methods in io.vertx.reactivex.sqlclient that return Buffer Modifier and Type Method Description Buffer
Row. getBuffer(String column)
Get a buffer value for the givencolumn
.Buffer
Tuple. getBuffer(int pos)
Get a buffer value atpos
.Methods in io.vertx.reactivex.sqlclient with parameters of type Buffer Modifier and Type Method Description Tuple
Tuple. addBuffer(Buffer value)
Add a buffer value at the end of the tuple. -
Uses of Buffer in io.vertx.redis.client
Methods in io.vertx.redis.client that return Buffer Modifier and Type Method Description default Buffer
Response. toBuffer()
Get this response as Buffer.Methods in io.vertx.redis.client with parameters of type Buffer Modifier and Type Method Description Request
Request. arg(Buffer arg)
Adds a String key argument -
Uses of Buffer in io.vertx.rxjava3
Methods in io.vertx.rxjava3 that return types with arguments of type Buffer Modifier and Type Method Description static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(Class<T> mappedType)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(Class<T> mappedType)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(Class<T> mappedType)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(Class<T> mappedType)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
-
Uses of Buffer in io.vertx.rxjava3.amqp
Methods in io.vertx.rxjava3.amqp that return Buffer Modifier and Type Method Description Buffer
AmqpMessage. bodyAsBinary()
Methods in io.vertx.rxjava3.amqp with parameters of type Buffer Modifier and Type Method Description AmqpMessageBuilder
AmqpMessageBuilder. withBufferAsBody(Buffer buffer)
-
Uses of Buffer in io.vertx.rxjava3.core
Methods in io.vertx.rxjava3.core that return types with arguments of type Buffer Modifier and Type Method Description static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(Class<T> mappedType)
static <T> FlowableTransformer<Buffer,T>
FlowableHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(Class<T> mappedType)
static <T> MaybeTransformer<Buffer,T>
MaybeHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(Class<T> mappedType)
static <T> ObservableTransformer<Buffer,T>
ObservableHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(TypeReference<T> mappedTypeRef)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(Class<T> mappedType)
static <T> SingleTransformer<Buffer,T>
SingleHelper. unmarshaller(Class<T> mappedType, ObjectCodec mapper)
-
Uses of Buffer in io.vertx.rxjava3.core.datagram
Methods in io.vertx.rxjava3.core.datagram that return types with arguments of type Buffer Modifier and Type Method Description WriteStream<Buffer>
DatagramSocket. sender(int port, String host)
Returns aWriteStream
able to send to theSocketAddress
.Methods in io.vertx.rxjava3.core.datagram with parameters of type Buffer Modifier and Type Method Description Completable
DatagramSocket. rxSend(Buffer packet, int port, String host)
Write the givenBuffer
to theSocketAddress
.Completable
DatagramSocket. send(Buffer packet, int port, String host)
Write the givenBuffer
to theSocketAddress
. -
Uses of Buffer in io.vertx.rxjava3.core.file
Methods in io.vertx.rxjava3.core.file that return Buffer Modifier and Type Method Description Buffer
FileSystem. readFileBlocking(String path)
Blocking version ofFileSystem.readFile(java.lang.String)
Methods in io.vertx.rxjava3.core.file that return types with arguments of type Buffer Modifier and Type Method 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)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Single<Buffer>
FileSystem. readFile(String path)
Reads the entire file as represented by the pathpath
as a , asynchronously.Single<Buffer>
AsyncFile. rxRead(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Single<Buffer>
FileSystem. rxReadFile(String path)
Reads the entire file as represented by the pathpath
as a , asynchronously.Flowable<Buffer>
AsyncFile. toFlowable()
Observable<Buffer>
AsyncFile. toObservable()
WriteStreamObserver<Buffer>
AsyncFile. toObserver()
WriteStreamSubscriber<Buffer>
AsyncFile. toSubscriber()
Methods in io.vertx.rxjava3.core.file with parameters of type Buffer Modifier and Type Method Description Completable
AsyncFile. end(Buffer data)
Same asWriteStream.end()
but writes some data to the stream before ending.Single<Buffer>
AsyncFile. read(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Completable
AsyncFile. rxEnd(Buffer data)
Same asWriteStream.end()
but writes some data to the stream before ending.Single<Buffer>
AsyncFile. rxRead(Buffer buffer, int offset, long position, int length)
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.Completable
AsyncFile. rxWrite(Buffer data)
Write some data to the stream.Completable
AsyncFile. rxWrite(Buffer buffer, long position)
Write aBuffer
to the file at positionposition
in the file, asynchronously.Completable
FileSystem. rxWriteFile(String path, Buffer data)
Creates the file, and writes the specifiedBuffer data
to the file represented by the pathpath
, asynchronously.Completable
AsyncFile. write(Buffer data)
Write some data to the stream.Completable
AsyncFile. write(Buffer buffer, long position)
Write aBuffer
to the file at positionposition
in the file, asynchronously.Completable
FileSystem. writeFile(String path, Buffer data)
Creates the file, and writes the specifiedBuffer data
to the file represented by the pathpath
, asynchronously.FileSystem
FileSystem. writeFileBlocking(String path, Buffer data)
Blocking version ofFileSystem.writeFile(java.lang.String, io.vertx.core.buffer.Buffer)
Method parameters in io.vertx.rxjava3.core.file with type arguments of type Buffer Modifier and Type Method Description AsyncFile
AsyncFile. handler(Handler<Buffer> handler)
Completable
AsyncFile. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
AsyncFile. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
. -
Uses of Buffer in io.vertx.rxjava3.core.http
Methods in io.vertx.rxjava3.core.http that return types with arguments of type Buffer Modifier and Type Method Description Single<Buffer>
HttpClientResponse. body()
Convenience method for receiving the entire request body in one piece.Single<Buffer>
HttpServerRequest. body()
Convenience method for receiving the entire request body in one piece.Single<Buffer>
HttpConnection. ping(Buffer data)
Send a frame to the remote endpoint.Pipe<Buffer>
ClientWebSocket. pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .Pipe<Buffer>
HttpClientResponse. 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>
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>
WebSocketBase. pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .Single<Buffer>
HttpClientResponse. rxBody()
Convenience method for receiving the entire request body in one piece.Single<Buffer>
HttpServerRequest. rxBody()
Convenience method for receiving the entire request body in one piece.Single<Buffer>
HttpConnection. rxPing(Buffer data)
Send a frame to the remote endpoint.Flowable<Buffer>
ClientWebSocket. toFlowable()
Flowable<Buffer>
HttpClientResponse. toFlowable()
Flowable<Buffer>
HttpServerFileUpload. toFlowable()
Flowable<Buffer>
HttpServerRequest. toFlowable()
Flowable<Buffer>
ServerWebSocket. toFlowable()
Flowable<Buffer>
WebSocket. toFlowable()
Observable<Buffer>
ClientWebSocket. toObservable()
Observable<Buffer>
HttpClientResponse. toObservable()
Observable<Buffer>
HttpServerFileUpload. toObservable()
Observable<Buffer>
HttpServerRequest. toObservable()
Observable<Buffer>
ServerWebSocket. toObservable()
Observable<Buffer>
WebSocket. toObservable()
WriteStreamObserver<Buffer>
ClientWebSocket. toObserver()
WriteStreamObserver<Buffer>
HttpClientRequest. toObserver()
WriteStreamObserver<Buffer>
HttpServerResponse. toObserver()
WriteStreamObserver<Buffer>
ServerWebSocket. toObserver()
WriteStreamObserver<Buffer>
WebSocket. toObserver()
WriteStreamSubscriber<Buffer>
ClientWebSocket. toSubscriber()
WriteStreamSubscriber<Buffer>
HttpClientRequest. toSubscriber()
WriteStreamSubscriber<Buffer>
HttpServerResponse. toSubscriber()
WriteStreamSubscriber<Buffer>
ServerWebSocket. toSubscriber()
WriteStreamSubscriber<Buffer>
WebSocket. toSubscriber()
Methods in io.vertx.rxjava3.core.http with parameters of type Buffer Modifier and Type Method Description Completable
ClientWebSocket. end(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
HttpClientRequest. end(Buffer chunk)
Same asHttpClientRequest.end(java.lang.String)
but writes some data to the request body before ending.Completable
HttpServerResponse. end(Buffer chunk)
Same asHttpServerResponse.end(java.lang.String)
but writes some data to the response body before ending.Completable
ServerWebSocket. end(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
WebSocket. end(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
WebSocketBase. end(Buffer data)
Same asWebSocketBase.end(io.vertx.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.Single<Buffer>
HttpConnection. ping(Buffer data)
Send a frame to the remote endpoint.Completable
ClientWebSocket. rxEnd(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
HttpClientRequest. rxEnd(Buffer chunk)
Same asHttpClientRequest.end(java.lang.String)
but writes some data to the request body before ending.Completable
HttpServerResponse. rxEnd(Buffer chunk)
Same asHttpServerResponse.end(java.lang.String)
but writes some data to the response body before ending.Completable
ServerWebSocket. rxEnd(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
WebSocket. rxEnd(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
WebSocketBase. rxEnd(Buffer data)
Same asWebSocketBase.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Single<Buffer>
HttpConnection. rxPing(Buffer data)
Send a frame to the remote endpoint.Single<HttpClientResponse>
HttpClientRequest. rxSend(Buffer body)
Send the request with a bufferbody
.Completable
HttpServerResponse. rxSend(Buffer body)
Send the request with a bufferbody
.Completable
ClientWebSocket. rxWrite(Buffer data)
Write some data to the stream.Completable
HttpClientRequest. rxWrite(Buffer data)
Write some data to the stream.Completable
HttpServerResponse. rxWrite(Buffer data)
Write some data to the stream.Completable
ServerWebSocket. rxWrite(Buffer data)
Write some data to the stream.Completable
WebSocket. rxWrite(Buffer data)
Write some data to the stream.Completable
WebSocketBase. rxWrite(Buffer data)
Write some data to the stream.Completable
ClientWebSocket. rxWriteBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
ServerWebSocket. rxWriteBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
WebSocket. rxWriteBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
WebSocketBase. rxWriteBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
HttpClientRequest. rxWriteCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.Completable
HttpServerResponse. rxWriteCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.Completable
ClientWebSocket. rxWriteFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
ServerWebSocket. rxWriteFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
WebSocket. rxWriteFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
WebSocketBase. rxWriteFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
ClientWebSocket. rxWritePing(Buffer data)
Writes a ping frame to the connection.Completable
ServerWebSocket. rxWritePing(Buffer data)
Writes a ping frame to the connection.Completable
WebSocket. rxWritePing(Buffer data)
Writes a ping frame to the connection.Completable
WebSocketBase. rxWritePing(Buffer data)
Writes a ping frame to the connection.Completable
ClientWebSocket. rxWritePong(Buffer data)
Writes a pong frame to the connection.Completable
ServerWebSocket. rxWritePong(Buffer data)
Writes a pong frame to the connection.Completable
WebSocket. rxWritePong(Buffer data)
Writes a pong frame to the connection.Completable
WebSocketBase. rxWritePong(Buffer data)
Writes a pong frame to the connection.Single<HttpClientResponse>
HttpClientRequest. send(Buffer body)
Send the request with a bufferbody
.Completable
HttpServerResponse. send(Buffer body)
Send the request with a bufferbody
.Completable
ClientWebSocket. write(Buffer data)
Write some data to the stream.Completable
HttpClientRequest. write(Buffer data)
Write some data to the stream.Completable
HttpServerResponse. write(Buffer data)
Write some data to the stream.Completable
ServerWebSocket. write(Buffer data)
Write some data to the stream.Completable
WebSocket. write(Buffer data)
Write some data to the stream.Completable
WebSocketBase. write(Buffer data)
Write some data to the stream.Completable
ClientWebSocket. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
ServerWebSocket. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
WebSocket. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
WebSocketBase. writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.Completable
HttpClientRequest. writeCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.Completable
HttpServerResponse. writeCustomFrame(int type, int flags, Buffer payload)
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.Completable
ClientWebSocket. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
ServerWebSocket. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
WebSocket. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
WebSocketBase. writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connectionCompletable
ClientWebSocket. writePing(Buffer data)
Writes a ping frame to the connection.Completable
ServerWebSocket. writePing(Buffer data)
Writes a ping frame to the connection.Completable
WebSocket. writePing(Buffer data)
Writes a ping frame to the connection.Completable
WebSocketBase. writePing(Buffer data)
Writes a ping frame to the connection.Completable
ClientWebSocket. writePong(Buffer data)
Writes a pong frame to the connection.Completable
ServerWebSocket. writePong(Buffer data)
Writes a pong frame to the connection.Completable
WebSocket. writePong(Buffer data)
Writes a pong frame to the connection.Completable
WebSocketBase. writePong(Buffer data)
Writes a pong frame to the connection.Method parameters in io.vertx.rxjava3.core.http with type arguments of type Buffer Modifier and Type Method Description ClientWebSocket
ClientWebSocket. binaryMessageHandler(Handler<Buffer> handler)
WebSocket
WebSocket. binaryMessageHandler(Handler<Buffer> handler)
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.ClientWebSocket
ClientWebSocket. handler(Handler<Buffer> handler)
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. pingHandler(Handler<Buffer> handler)
Set an handler notified when a frame is received from the remote endpoint.Completable
ClientWebSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpClientResponse. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpServerFileUpload. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpServerRequest. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
ServerWebSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
WebSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
WebSocketBase. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.ClientWebSocket
ClientWebSocket. pongHandler(Handler<Buffer> handler)
WebSocket
WebSocket. pongHandler(Handler<Buffer> handler)
WebSocketBase
WebSocketBase. pongHandler(Handler<Buffer> handler)
Set a pong frame handler on the connection.Completable
ClientWebSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpClientResponse. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpServerFileUpload. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
HttpServerRequest. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
ServerWebSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
WebSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
WebSocketBase. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Single<HttpClientResponse>
HttpClientRequest. rxSend(Flowable<Buffer> body)
Send the request with a streambody
.Completable
HttpServerResponse. rxSend(Flowable<Buffer> body)
Send the request with a streambody
.Single<HttpClientResponse>
HttpClientRequest. send(Flowable<Buffer> body)
Send the request with a streambody
.Completable
HttpServerResponse. send(Flowable<Buffer> body)
Send the request with a streambody
. -
Uses of Buffer in io.vertx.rxjava3.core.net
Methods in io.vertx.rxjava3.core.net that return types with arguments of type Buffer Modifier and Type Method 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()
Methods in io.vertx.rxjava3.core.net with parameters of type Buffer Modifier and Type Method Description Completable
NetSocket. end(Buffer data)
Same asNetSocket.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
NetSocket. rxEnd(Buffer data)
Same asNetSocket.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
NetSocket. rxUpgradeToSsl(Buffer msg)
LikeNetSocket.upgradeToSsl()
with the default SSL options and without indicating a server name.Completable
NetSocket. rxUpgradeToSsl(SSLOptions sslOptions, Buffer msg)
LikeNetSocket.upgradeToSsl()
without indicating a server nameCompletable
NetSocket. rxUpgradeToSsl(SSLOptions sslOptions, String serverName, Buffer upgrade)
Upgrade the channel to use SSL/TLS, in other words proceeds to the TLS handshake.Completable
NetSocket. rxUpgradeToSsl(String serverName, Buffer msg)
LikeNetSocket.upgradeToSsl()
with the default SSL options.Completable
NetSocket. rxWrite(Buffer data)
Write some data to the stream.Completable
NetSocket. upgradeToSsl(Buffer msg)
LikeNetSocket.upgradeToSsl()
with the default SSL options and without indicating a server name.Completable
NetSocket. upgradeToSsl(SSLOptions sslOptions, Buffer msg)
LikeNetSocket.upgradeToSsl()
without indicating a server nameCompletable
NetSocket. upgradeToSsl(SSLOptions sslOptions, String serverName, Buffer upgrade)
Upgrade the channel to use SSL/TLS, in other words proceeds to the TLS handshake.Completable
NetSocket. upgradeToSsl(String serverName, Buffer msg)
LikeNetSocket.upgradeToSsl()
with the default SSL options.Completable
NetSocket. write(Buffer data)
Write some data to the stream.Method parameters in io.vertx.rxjava3.core.net with type arguments of type Buffer Modifier and Type Method Description NetSocket
NetSocket. handler(Handler<Buffer> handler)
Completable
NetSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
NetSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
. -
Uses of Buffer in io.vertx.rxjava3.core.parsetools
Methods in io.vertx.rxjava3.core.parsetools that return types with arguments of type Buffer Modifier and Type Method 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()
Methods in io.vertx.rxjava3.core.parsetools with parameters of type Buffer Modifier and Type Method Description void
RecordParser. delimitedMode(Buffer delim)
Flip the parser into delimited mode, and where the delimiter can be represented by the delimiterdelim
.void
JsonParser. handle(Buffer event)
Something has happened, so handle it.void
RecordParser. handle(Buffer buffer)
This method is called to provide the parser with data.static RecordParser
RecordParser. newDelimited(Buffer delim)
Create a newRecordParser
instance, initially in delimited mode, and where the delimiter can be represented by theBuffer
delim.static RecordParser
RecordParser. newDelimited(Buffer delim, Flowable<Buffer> stream)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but wraps thestream
.static RecordParser
RecordParser. newDelimited(Buffer delim, Handler<Buffer> output)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but set theoutput
that will receive whole records which have been parsed.JsonParser
JsonParser. write(Buffer buffer)
Handle aBuffer
, pretty much like callingHandler
.Method parameters in io.vertx.rxjava3.core.parsetools with type arguments of type Buffer Modifier and Type Method Description RecordParser
RecordParser. handler(Handler<Buffer> handler)
static RecordParser
RecordParser. newDelimited(Buffer delim, Flowable<Buffer> stream)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but wraps thestream
.static RecordParser
RecordParser. newDelimited(Buffer delim, Handler<Buffer> output)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but set theoutput
that will receive whole records which have been parsed.static RecordParser
RecordParser. newDelimited(String delim, Flowable<Buffer> stream)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but wraps thestream
.static RecordParser
RecordParser. newDelimited(String delim, Handler<Buffer> output)
LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)
but set theoutput
that will receive whole records which have been parsed.static RecordParser
RecordParser. newFixed(int size, Flowable<Buffer> stream)
LikeRecordParser.newFixed(int)
but wraps thestream
.static RecordParser
RecordParser. newFixed(int size, Handler<Buffer> output)
LikeRecordParser.newFixed(int)
but set theoutput
that will receive whole records which have been parsed.static JsonParser
JsonParser. newParser(Flowable<Buffer> stream)
Create a newJsonParser
instance.Completable
RecordParser. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
RecordParser. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.void
RecordParser. setOutput(Handler<Buffer> output)
-
Uses of Buffer in io.vertx.rxjava3.ext.mail
Methods in io.vertx.rxjava3.ext.mail that return Buffer Modifier and Type Method Description Buffer
MailAttachment. getData()
get the dataMethods in io.vertx.rxjava3.ext.mail that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
MailAttachment. getStream()
Gets the data stream.Methods in io.vertx.rxjava3.ext.mail with parameters of type Buffer Modifier and Type Method Description MailAttachment
MailAttachment. setData(Buffer data)
set the dataMethod parameters in io.vertx.rxjava3.ext.mail with type arguments of type Buffer Modifier and Type Method Description MailAttachment
MailAttachment. setStream(Flowable<Buffer> stream)
Sets the data stream. -
Uses of Buffer in io.vertx.rxjava3.ext.mongo
Methods in io.vertx.rxjava3.ext.mongo that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
MongoGridFsClient. readByFileName(String fileName)
Read file by name to ReadStreamReadStream<Buffer>
MongoGridFsClient. readByFileNameWithOptions(String fileName, GridFsDownloadOptions options)
Read file by name to ReadStream with optionsReadStream<Buffer>
MongoGridFsClient. readById(String id)
Read file by id to ReadStream -
Uses of Buffer in io.vertx.rxjava3.ext.stomp
Methods in io.vertx.rxjava3.ext.stomp with parameters of type Buffer Modifier and Type Method Description Single<Frame>
StompClientConnection. rxSend(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. rxSend(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. rxSend(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.Single<Frame>
StompClientConnection. send(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. send(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. send(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.StompServerConnection
StompServerConnection. write(Buffer buffer)
Writes the given buffer to the socket. -
Uses of Buffer in io.vertx.rxjava3.ext.web
Methods in io.vertx.rxjava3.ext.web that return Buffer Modifier and Type Method Description Buffer
RequestBody. buffer()
Methods in io.vertx.rxjava3.ext.web with parameters of type Buffer Modifier and Type Method Description Completable
RoutingContext. end(Buffer buffer)
Shortcut to the response end.Completable
RoutingContext. rxEnd(Buffer buffer)
Shortcut to the response end. -
Uses of Buffer in io.vertx.rxjava3.ext.web.client
Methods in io.vertx.rxjava3.ext.web.client that return Buffer Modifier and Type Method Description Buffer
HttpResponse. bodyAsBuffer()
Methods in io.vertx.rxjava3.ext.web.client that return types with arguments of type Buffer Modifier and Type Method Description 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(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(UriTemplate requestURI)
Create an HTTP DELETE request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP DELETE request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP DELETE request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP GET request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP GET request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP GET request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP HEAD request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP HEAD request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP HEAD request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP PATCH request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP PATCH request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP PATCH request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP POST request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP POST request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP POST request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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(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(UriTemplate requestURI)
Create an HTTP PUT request to send to the server at the default 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, UriTemplate requestURI)
Create an HTTP PUT request to send to the server at the specified host and default 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(UriTemplate absoluteURI)
Create an HTTP PUT request to send to the server using an absolute URI, specifying a response handler to receive the responseHttpRequest<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 responseHttpRequest<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, 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, UriTemplate requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theport
andhost
parameters.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, int port, String host, String requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theport
andhost
parameters.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, RequestOptions options)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theoptions
parameter.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, UriTemplate requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of the default port and default host.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of the default port and default host.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String host, UriTemplate requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of the default port andhost
parameter.HttpRequest<Buffer>
WebClient. request(HttpMethod method, SocketAddress serverAddress, String host, String requestURI)
LikeWebClient.request(io.vertx.core.http.HttpMethod, int, java.lang.String, java.lang.String)
using theserverAddress
parameter to connect to the server instead of the default port andhost
parameter.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. 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, UriTemplate 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, 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, UriTemplate absoluteURI)
LikeWebClient.requestAbs(io.vertx.core.http.HttpMethod, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theabsoluteURI
parameter.HttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, SocketAddress serverAddress, String absoluteURI)
LikeWebClient.requestAbs(io.vertx.core.http.HttpMethod, java.lang.String)
using theserverAddress
parameter to connect to the server instead of theabsoluteURI
parameter.HttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, UriTemplate absoluteURI)
Create an HTTP request to send to the server using an absolute URIHttpRequest<Buffer>
WebClient. requestAbs(HttpMethod method, String absoluteURI)
Create an HTTP request to send to the server using an absolute URIMethods in io.vertx.rxjava3.ext.web.client with parameters of type Buffer Modifier and Type Method Description HttpRequest<T>
HttpRequest. basicAuthentication(Buffer id, Buffer password)
Configure the request to perform basic access authentication.Single<HttpResponse<T>>
HttpRequest. rxSendBuffer(Buffer body)
LikeHttpRequest.send()
but with an HTTP requestbody
buffer.Single<HttpResponse<T>>
HttpRequest. sendBuffer(Buffer body)
LikeHttpRequest.send()
but with an HTTP requestbody
buffer.Method parameters in io.vertx.rxjava3.ext.web.client with type arguments of type Buffer Modifier and Type Method Description Single<HttpResponse<T>>
HttpRequest. rxSendStream(Flowable<Buffer> body)
LikeHttpRequest.send()
but with an HTTP requestbody
stream.Single<HttpResponse<T>>
HttpRequest. sendStream(Flowable<Buffer> body)
LikeHttpRequest.send()
but with an HTTP requestbody
stream. -
Uses of Buffer in io.vertx.rxjava3.ext.web.codec
Methods in io.vertx.rxjava3.ext.web.codec that return types with arguments of type Buffer Modifier and Type Method Description static BodyCodec<Buffer>
BodyCodec. buffer()
Method parameters in io.vertx.rxjava3.ext.web.codec with type arguments of type Buffer Modifier and Type Method 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 thedecode
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. -
Uses of Buffer in io.vertx.rxjava3.ext.web.common.template
Methods in io.vertx.rxjava3.ext.web.common.template that return types with arguments of type Buffer Modifier and Type Method 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. -
Uses of Buffer in io.vertx.rxjava3.ext.web.handler.sockjs
Methods in io.vertx.rxjava3.ext.web.handler.sockjs that return types with arguments of type Buffer Modifier and Type Method 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()
Methods in io.vertx.rxjava3.ext.web.handler.sockjs with parameters of type Buffer Modifier and Type Method Description Completable
SockJSSocket. end(Buffer data)
Same asSockJSSocket.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
SockJSSocket. rxEnd(Buffer data)
Same asSockJSSocket.end(io.vertx.core.buffer.Buffer)
but writes some data to the stream before ending.Completable
SockJSSocket. rxWrite(Buffer data)
Completable
SockJSSocket. write(Buffer data)
Method parameters in io.vertx.rxjava3.ext.web.handler.sockjs with type arguments of type Buffer Modifier and Type Method Description SockJSSocket
SockJSSocket. handler(Handler<Buffer> handler)
Completable
SockJSSocket. pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Completable
SockJSSocket. rxPipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
. -
Uses of Buffer in io.vertx.rxjava3.ext.web.multipart
Methods in io.vertx.rxjava3.ext.web.multipart that return Buffer Modifier and Type Method Description Buffer
FormDataPart. content()
Methods in io.vertx.rxjava3.ext.web.multipart with parameters of type Buffer Modifier and Type Method 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. -
Uses of Buffer in io.vertx.rxjava3.ext.web.sstore.cookie
Methods in io.vertx.rxjava3.ext.web.sstore.cookie with parameters of type Buffer Modifier and Type Method Description static CookieSessionStore
CookieSessionStore. create(Vertx vertx, String secret, Buffer salt)
Creates a CookieSessionStore. -
Uses of Buffer in io.vertx.rxjava3.ext.web.validation
Methods in io.vertx.rxjava3.ext.web.validation that return Buffer Modifier and Type Method Description Buffer
RequestParameter. getBuffer()
-
Uses of Buffer in io.vertx.rxjava3.grpc.client
Methods in io.vertx.rxjava3.grpc.client that return types with arguments of type Buffer Modifier and Type Method Description Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service. -
Uses of Buffer in io.vertx.rxjava3.grpc.common
Fields in io.vertx.rxjava3.grpc.common with type parameters of type Buffer Modifier and Type Field Description static GrpcMessageDecoder<Buffer>
GrpcMessageDecoder. IDENTITY
static GrpcMessageEncoder<Buffer>
GrpcMessageEncoder. IDENTITY
Methods in io.vertx.rxjava3.grpc.common that return Buffer Modifier and Type Method Description Buffer
GrpcMessage. payload()
Methods in io.vertx.rxjava3.grpc.common with parameters of type Buffer Modifier and Type Method Description static GrpcMessage
GrpcMessage. message(String encoding, Buffer payload)
static GrpcMessage
GrpcMessage. message(String encoding, WireFormat format, Buffer payload)
-
Uses of Buffer in io.vertx.rxjava3.grpc.server
Method parameters in io.vertx.rxjava3.grpc.server with type arguments of type Buffer Modifier and Type Method 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. -
Uses of Buffer in io.vertx.rxjava3.httpproxy
Methods in io.vertx.rxjava3.httpproxy that return types with arguments of type Buffer Modifier and Type Method Description ReadStream<Buffer>
Body. stream()
Get stream of theBody
.Methods in io.vertx.rxjava3.httpproxy with parameters of type Buffer Modifier and Type Method Description static Body
Body. body(Buffer buffer)
Create a newBody
instance.Method parameters in io.vertx.rxjava3.httpproxy with type arguments of type Buffer Modifier and Type Method Description static Body
Body. body(Flowable<Buffer> stream)
Create a newBody
instance.static Body
Body. body(Flowable<Buffer> stream, long len)
Create a newBody
instance. -
Uses of Buffer in io.vertx.rxjava3.httpproxy.interceptors
Methods in io.vertx.rxjava3.httpproxy.interceptors that return Buffer Modifier and Type Method Description Buffer
BodyTransformer. apply(Buffer in)
Methods in io.vertx.rxjava3.httpproxy.interceptors with parameters of type Buffer Modifier and Type Method Description Buffer
BodyTransformer. apply(Buffer in)
-
Uses of Buffer in io.vertx.rxjava3.kafka.client.producer
Methods in io.vertx.rxjava3.kafka.client.producer that return Buffer Modifier and Type Method Description Buffer
KafkaHeader. value()
Methods in io.vertx.rxjava3.kafka.client.producer with parameters of type Buffer Modifier and Type Method Description KafkaProducerRecord<K,V>
KafkaProducerRecord. addHeader(String key, Buffer value)
LikeKafkaProducerRecord.addHeader(java.lang.String, java.lang.String)
but with a key/value pairstatic KafkaHeader
KafkaHeader. header(String key, Buffer value)
-
Uses of Buffer in io.vertx.rxjava3.mqtt
Methods in io.vertx.rxjava3.mqtt with parameters of type Buffer Modifier and Type Method Description Single<Integer>
MqttClient. publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT serverSingle<Integer>
MqttEndpoint. publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT clientSingle<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 messageIdSingle<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 messageIdSingle<Integer>
MqttClient. rxPublish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT serverSingle<Integer>
MqttEndpoint. rxPublish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)
Sends the PUBLISH message to the remote MQTT clientSingle<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 messageIdSingle<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 -
Uses of Buffer in io.vertx.rxjava3.mqtt.messages
Methods in io.vertx.rxjava3.mqtt.messages that return Buffer Modifier and Type Method Description Buffer
MqttAuthenticationExchangeMessage. authenticationData()
Buffer
MqttPublishMessage. payload()
Methods in io.vertx.rxjava3.mqtt.messages with parameters of type Buffer Modifier and Type Method Description static MqttPublishMessage
MqttPublishMessage. create(int messageId, MqttQoS qosLevel, boolean isDup, boolean isRetain, String topicName, Buffer payload, MqttProperties properties)
Create a concrete instance of a Vert.x publish message -
Uses of Buffer in io.vertx.rxjava3.openapi.validation
Methods in io.vertx.rxjava3.openapi.validation with parameters of type Buffer Modifier and Type Method Description static ValidatableResponse
ValidatableResponse. create(int statusCode, Buffer body, String contentType)
Creates a newValidatableResponse
object based on the passed parameters.static ValidatableResponse
ValidatableResponse. create(int statusCode, Map<String,String> headers, Buffer body, String contentType)
Creates a newValidatableResponse
object based on the passed parameters. -
Uses of Buffer in io.vertx.rxjava3.rabbitmq
Methods in io.vertx.rxjava3.rabbitmq that return Buffer Modifier and Type Method Description Buffer
RabbitMQMessage. body()
Methods in io.vertx.rxjava3.rabbitmq with parameters of type Buffer Modifier and Type Method 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. -
Uses of Buffer in io.vertx.rxjava3.sqlclient
Methods in io.vertx.rxjava3.sqlclient that return Buffer Modifier and Type Method Description Buffer
Row. getBuffer(String column)
Get a buffer value for the givencolumn
.Buffer
Tuple. getBuffer(int pos)
Get a buffer value atpos
.Methods in io.vertx.rxjava3.sqlclient with parameters of type Buffer Modifier and Type Method Description Tuple
Tuple. addBuffer(Buffer value)
Add a buffer value at the end of the tuple. -
Uses of Buffer in io.vertx.serviceproxy
Methods in io.vertx.serviceproxy with parameters of type Buffer Modifier and Type Method Description ServiceException
ServiceExceptionMessageCodec. decodeFromWire(int pos, Buffer buffer)
void
ServiceExceptionMessageCodec. encodeToWire(Buffer buffer, ServiceException body)
-
Uses of Buffer in io.vertx.sqlclient
Methods in io.vertx.sqlclient that return Buffer Modifier and Type Method Description default Buffer[]
Row. getArrayOfBuffers(String column)
Get an array ofBuffer
value for the givencolumn
.default Buffer[]
Tuple. getArrayOfBuffers(int pos)
Get an array ofBuffer
value atpos
.default Buffer
Row. getBuffer(String column)
Get a buffer value for the givencolumn
.default Buffer
Tuple. getBuffer(int pos)
Get a buffer value atpos
.Methods in io.vertx.sqlclient with parameters of type Buffer Modifier and Type Method Description default Tuple
Tuple. addArrayOfBuffer(Buffer[] value)
Add an array ofBuffer
value at the end of the tuple.default Tuple
Tuple. addBuffer(Buffer value)
Add a buffer value at the end of the tuple. -
Uses of Buffer in io.vertx.tracing.zipkin
Methods in io.vertx.tracing.zipkin with parameters of type Buffer Modifier and Type Method Description HttpSenderOptions
HttpSenderOptions. addCrlValue(Buffer crlValue)
-