Uses of Class
io.vertx.mutiny.core.buffer.Buffer
Packages that use Buffer
Package
Description
-
Uses of Buffer in io.vertx.mutiny.amqp
Methods in io.vertx.mutiny.amqp that return BufferMethods in io.vertx.mutiny.amqp with parameters of type Buffer -
Uses of Buffer in io.vertx.mutiny.core.buffer
Fields in io.vertx.mutiny.core.buffer with type parameters of type BufferMethods in io.vertx.mutiny.core.buffer that return BufferModifier and TypeMethodDescriptionBuffer.appendBuffer
(Buffer buff) Buffer.appendBuffer
(Buffer buff, int offset, int len) Buffer.appendByte
(byte b) Buffer.appendBytes
(byte[] bytes) Buffer.appendBytes
(byte[] bytes, int offset, int len) Buffer.appendDouble
(double d) Buffer.appendFloat
(float f) Buffer.appendInt
(int i) Buffer.appendIntLE
(int i) Buffer.appendLong
(long l) Buffer.appendLongLE
(long l) Buffer.appendMedium
(int i) Buffer.appendMediumLE
(int i) Buffer.appendShort
(short s) Buffer.appendShortLE
(short s) Buffer.appendString
(String str) Buffer.appendString
(String str, String enc) Buffer.appendUnsignedByte
(short b) Buffer.appendUnsignedInt
(long i) Buffer.appendUnsignedIntLE
(long i) Buffer.appendUnsignedShort
(int s) Buffer.appendUnsignedShortLE
(int s) static Buffer
Buffer.buffer()
static Buffer
Buffer.buffer
(byte[] bytes) static Buffer
Buffer.buffer
(int initialSizeHint) static Buffer
Buffer.buffer
(io.netty.buffer.ByteBuf byteBuf) Deprecated.removed from public API in Vert.x 5static Buffer
static Buffer
Buffer.copy()
Buffer.getBuffer
(int start, int end) Buffer.getBytes
(byte[] dst) Buffer.getBytes
(byte[] dst, int dstIndex) Buffer.getBytes
(int start, int end, byte[] dst) Buffer.getBytes
(int start, int end, byte[] dst, int dstIndex) static Buffer
Buffer.newInstance
(io.vertx.core.buffer.Buffer arg) Buffer.setByte
(int pos, byte b) Buffer.setBytes
(int pos, byte[] b) Buffer.setBytes
(int pos, byte[] b, int offset, int len) Buffer.setBytes
(int pos, ByteBuffer b) Buffer.setDouble
(int pos, double d) Buffer.setFloat
(int pos, float f) Buffer.setInt
(int pos, int i) Buffer.setIntLE
(int pos, int i) Buffer.setLong
(int pos, long l) Buffer.setLongLE
(int pos, long l) Buffer.setMedium
(int pos, int i) Buffer.setMediumLE
(int pos, int i) Buffer.setShort
(int pos, short s) Buffer.setShortLE
(int pos, short s) Buffer.setUnsignedByte
(int pos, short b) Buffer.setUnsignedInt
(int pos, long i) Buffer.setUnsignedIntLE
(int pos, long i) Buffer.setUnsignedShort
(int pos, int s) Buffer.setUnsignedShortLE
(int pos, int s) Buffer.slice()
Buffer.slice
(int start, int end) Methods in io.vertx.mutiny.core.buffer with parameters of type Buffer -
Uses of Buffer in io.vertx.mutiny.core.datagram
Methods in io.vertx.mutiny.core.datagram that return BufferMethods in io.vertx.mutiny.core.datagram that return types with arguments of type BufferModifier and TypeMethodDescriptionMethods in io.vertx.mutiny.core.datagram with parameters of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
Write the givenBuffer
to theSocketAddress
.DatagramSocket.sendAndAwait
(Buffer packet, int port, String host) Blocking variant ofDatagramSocket.send(io.vertx.mutiny.core.buffer.Buffer,int,String)
.DatagramSocket.sendAndForget
(Buffer packet, int port, String host) Variant ofDatagramSocket.send(io.vertx.mutiny.core.buffer.Buffer,int,String)
that ignores the result of the operation. -
Uses of Buffer in io.vertx.mutiny.core.file
Methods in io.vertx.mutiny.core.file that return BufferModifier and TypeMethodDescriptionAsyncFile.readAndAwait
(Buffer buffer, int offset, long position, int length) Blocking variant ofAsyncFile.read(io.vertx.mutiny.core.buffer.Buffer,int,long,int)
.FileSystem.readFileAndAwait
(String path) Blocking variant ofFileSystem.readFile(String)
.FileSystem.readFileBlocking
(String path) Methods in io.vertx.mutiny.core.file that return types with arguments of type BufferModifier and TypeMethodDescriptionAsyncFile.pipe()
io.smallrye.mutiny.Uni<Buffer>
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.io.smallrye.mutiny.Uni<Buffer>
Reads the entire file as represented by the pathpath
as a , asynchronously.AsyncFile.toBlockingIterable()
AsyncFile.toBlockingStream()
io.smallrye.mutiny.Multi<Buffer>
AsyncFile.toMulti()
AsyncFile.toSubscriber()
Methods in io.vertx.mutiny.core.file with parameters of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesAsyncFile.endAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
.void
AsyncFile.endAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Buffer>
Readslength
bytes of data from the file at positionposition
in the file, asynchronously.AsyncFile.readAndAwait
(Buffer buffer, int offset, long position, int length) Blocking variant ofAsyncFile.read(io.vertx.mutiny.core.buffer.Buffer,int,long,int)
.AsyncFile.readAndForget
(Buffer buffer, int offset, long position, int length) Variant ofAsyncFile.read(io.vertx.mutiny.core.buffer.Buffer,int,long,int)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Write aBuffer
to the file at positionposition
in the file, asynchronously.AsyncFile.writeAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.AsyncFile.writeAndAwait
(Buffer buffer, long position) Blocking variant ofAsyncFile.write(io.vertx.mutiny.core.buffer.Buffer,long)
.void
AsyncFile.writeAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
AsyncFile.writeAndForget
(Buffer buffer, long position) Variant ofAsyncFile.write(io.vertx.mutiny.core.buffer.Buffer,long)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
Creates the file, and writes the specifiedBuffer data
to the file represented by the pathpath
, asynchronously.FileSystem.writeFileAndAwait
(String path, Buffer data) Blocking variant ofFileSystem.writeFile(String,io.vertx.mutiny.core.buffer.Buffer)
.FileSystem.writeFileAndForget
(String path, Buffer data) Variant ofFileSystem.writeFile(String,io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.FileSystem.writeFileBlocking
(String path, Buffer data) Method parameters in io.vertx.mutiny.core.file with type arguments of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
AsyncFile.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.AsyncFile.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.void
AsyncFile.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation. -
Uses of Buffer in io.vertx.mutiny.core.http
Fields in io.vertx.mutiny.core.http with type parameters of type BufferMethods in io.vertx.mutiny.core.http that return BufferModifier and TypeMethodDescriptionWebSocketFrame.binaryData()
HttpClientResponse.bodyAndAwait()
Blocking variant ofHttpClientResponse.body()
.HttpServerRequest.bodyAndAwait()
Blocking variant ofHttpServerRequest.body()
.HttpFrame.payload()
HttpConnection.pingAndAwait
(Buffer data) Blocking variant ofHttpConnection.ping(io.vertx.mutiny.core.buffer.Buffer)
.Methods in io.vertx.mutiny.core.http that return types with arguments of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Buffer>
HttpClientResponse.body()
Same asHttpClientResponse.body()
but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Buffer>
HttpServerRequest.body()
Same asHttpServerRequest.body()
but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Buffer>
Send a frame to the remote endpoint.ClientWebSocket.pipe()
HttpClientResponse.pipe()
HttpServerFileUpload.pipe()
HttpServerRequest.pipe()
ServerWebSocket.pipe()
WebSocket.pipe()
WebSocketBase.pipe()
ClientWebSocket.toBlockingIterable()
HttpClientResponse.toBlockingIterable()
HttpServerFileUpload.toBlockingIterable()
HttpServerRequest.toBlockingIterable()
ServerWebSocket.toBlockingIterable()
WebSocket.toBlockingIterable()
ClientWebSocket.toBlockingStream()
HttpClientResponse.toBlockingStream()
HttpServerFileUpload.toBlockingStream()
HttpServerRequest.toBlockingStream()
ServerWebSocket.toBlockingStream()
WebSocket.toBlockingStream()
io.smallrye.mutiny.Multi<Buffer>
ClientWebSocket.toMulti()
io.smallrye.mutiny.Multi<Buffer>
HttpClientResponse.toMulti()
io.smallrye.mutiny.Multi<Buffer>
HttpServerFileUpload.toMulti()
io.smallrye.mutiny.Multi<Buffer>
HttpServerRequest.toMulti()
io.smallrye.mutiny.Multi<Buffer>
ServerWebSocket.toMulti()
io.smallrye.mutiny.Multi<Buffer>
WebSocket.toMulti()
ClientWebSocket.toSubscriber()
HttpClientRequest.toSubscriber()
HttpServerResponse.toSubscriber()
ServerWebSocket.toSubscriber()
WebSocket.toSubscriber()
Methods in io.vertx.mutiny.core.http with parameters of type BufferModifier and TypeMethodDescriptionstatic WebSocketFrame
WebSocketFrame.binaryFrame
(Buffer data, boolean isFinal) static WebSocketFrame
WebSocketFrame.continuationFrame
(Buffer data, boolean isFinal) io.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same asHttpClientRequest.end(java.lang.String)
but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same asHttpServerResponse.end()
but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesClientWebSocket.endAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
.HttpClientRequest.endAndAwait
(Buffer chunk) Blocking variant ofHttpClientRequest.end(io.vertx.mutiny.core.buffer.Buffer)
.HttpServerResponse.endAndAwait
(Buffer chunk) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
.ServerWebSocket.endAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
.WebSocket.endAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
.WebSocketBase.endAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
.void
ClientWebSocket.endAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
HttpClientRequest.endAndForget
(Buffer chunk) Variant ofHttpClientRequest.end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
HttpServerResponse.endAndForget
(Buffer chunk) Variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
ServerWebSocket.endAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
WebSocket.endAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
WebSocketBase.endAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Buffer>
Send a frame to the remote endpoint.HttpConnection.pingAndAwait
(Buffer data) Blocking variant ofHttpConnection.ping(io.vertx.mutiny.core.buffer.Buffer)
.HttpConnection.pingAndForget
(Buffer data) Variant ofHttpConnection.ping(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.static WebSocketFrame
static WebSocketFrame
io.smallrye.mutiny.Uni<HttpClientResponse>
Send the request with a bufferbody
.io.smallrye.mutiny.Uni<Void>
Send the request with a bufferbody
.HttpClientRequest.sendAndAwait
(Buffer body) Blocking variant ofHttpClientRequest.send(io.vertx.mutiny.core.buffer.Buffer)
.HttpServerResponse.sendAndAwait
(Buffer body) Blocking variant ofHttpServerResponse.send(io.vertx.mutiny.core.buffer.Buffer)
.void
HttpClientRequest.sendAndForget
(Buffer body) Variant ofHttpClientRequest.send(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
HttpServerResponse.sendAndForget
(Buffer body) Variant ofHttpServerResponse.send(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesClientWebSocket.writeAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.HttpClientRequest.writeAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.HttpServerResponse.writeAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.ServerWebSocket.writeAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.WebSocket.writeAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.WebSocketBase.writeAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.void
ClientWebSocket.writeAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
HttpClientRequest.writeAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
HttpServerResponse.writeAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
ServerWebSocket.writeAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
WebSocket.writeAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
WebSocketBase.writeAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
ClientWebSocket.writeBinaryMessage
(Buffer data) io.smallrye.mutiny.Uni<Void>
ServerWebSocket.writeBinaryMessage
(Buffer data) io.smallrye.mutiny.Uni<Void>
WebSocket.writeBinaryMessage
(Buffer data) io.smallrye.mutiny.Uni<Void>
WebSocketBase.writeBinaryMessage
(Buffer data) Same asWebSocketBase.writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
but with anhandler
called when the operation completesClientWebSocket.writeBinaryMessageAndAwait
(Buffer data) ServerWebSocket.writeBinaryMessageAndAwait
(Buffer data) WebSocket.writeBinaryMessageAndAwait
(Buffer data) WebSocketBase.writeBinaryMessageAndAwait
(Buffer data) Blocking variant ofWebSocketBase.writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
.ClientWebSocket.writeBinaryMessageAndForget
(Buffer data) ServerWebSocket.writeBinaryMessageAndForget
(Buffer data) WebSocket.writeBinaryMessageAndForget
(Buffer data) WebSocketBase.writeBinaryMessageAndForget
(Buffer data) Variant ofWebSocketBase.writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.HttpClientRequest.writeCustomFrame
(int type, int flags, Buffer payload) HttpServerResponse.writeCustomFrame
(int type, int flags, Buffer payload) io.smallrye.mutiny.Uni<Void>
ClientWebSocket.writeFinalBinaryFrame
(Buffer data) io.smallrye.mutiny.Uni<Void>
ServerWebSocket.writeFinalBinaryFrame
(Buffer data) io.smallrye.mutiny.Uni<Void>
WebSocket.writeFinalBinaryFrame
(Buffer data) io.smallrye.mutiny.Uni<Void>
WebSocketBase.writeFinalBinaryFrame
(Buffer data) Same asWebSocketBase.writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
but with anhandler
called when the operation completesClientWebSocket.writeFinalBinaryFrameAndAwait
(Buffer data) ServerWebSocket.writeFinalBinaryFrameAndAwait
(Buffer data) WebSocket.writeFinalBinaryFrameAndAwait
(Buffer data) WebSocketBase.writeFinalBinaryFrameAndAwait
(Buffer data) Blocking variant ofWebSocketBase.writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
.ClientWebSocket.writeFinalBinaryFrameAndForget
(Buffer data) ServerWebSocket.writeFinalBinaryFrameAndForget
(Buffer data) WebSocket.writeFinalBinaryFrameAndForget
(Buffer data) WebSocketBase.writeFinalBinaryFrameAndForget
(Buffer data) Variant ofWebSocketBase.writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
io.smallrye.mutiny.Uni<Void>
io.smallrye.mutiny.Uni<Void>
io.smallrye.mutiny.Uni<Void>
Writes a ping frame to the connection.ClientWebSocket.writePingAndAwait
(Buffer data) ServerWebSocket.writePingAndAwait
(Buffer data) WebSocket.writePingAndAwait
(Buffer data) WebSocketBase.writePingAndAwait
(Buffer data) Blocking variant ofWebSocketBase.writePing(io.vertx.mutiny.core.buffer.Buffer)
.ClientWebSocket.writePingAndForget
(Buffer data) ServerWebSocket.writePingAndForget
(Buffer data) WebSocket.writePingAndForget
(Buffer data) WebSocketBase.writePingAndForget
(Buffer data) Variant ofWebSocketBase.writePing(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
io.smallrye.mutiny.Uni<Void>
io.smallrye.mutiny.Uni<Void>
io.smallrye.mutiny.Uni<Void>
Writes a pong frame to the connection.ClientWebSocket.writePongAndAwait
(Buffer data) ServerWebSocket.writePongAndAwait
(Buffer data) WebSocket.writePongAndAwait
(Buffer data) WebSocketBase.writePongAndAwait
(Buffer data) Blocking variant ofWebSocketBase.writePong(io.vertx.mutiny.core.buffer.Buffer)
.ClientWebSocket.writePongAndForget
(Buffer data) ServerWebSocket.writePongAndForget
(Buffer data) WebSocket.writePongAndForget
(Buffer data) WebSocketBase.writePongAndForget
(Buffer data) Variant ofWebSocketBase.writePong(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.Method parameters in io.vertx.mutiny.core.http with type arguments of type BufferModifier and TypeMethodDescriptionClientWebSocket.binaryMessageHandler
(Consumer<Buffer> handler) ServerWebSocket.binaryMessageHandler
(Consumer<Buffer> handler) WebSocket.binaryMessageHandler
(Consumer<Buffer> handler) WebSocketBase.binaryMessageHandler
(Consumer<Buffer> handler) HttpClientResponse.bodyHandler
(Consumer<Buffer> bodyHandler) HttpServerRequest.bodyHandler
(Consumer<Buffer> bodyHandler) HttpConnection.pingHandler
(Consumer<Buffer> handler) io.smallrye.mutiny.Uni<Void>
ClientWebSocket.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.io.smallrye.mutiny.Uni<Void>
HttpClientResponse.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.io.smallrye.mutiny.Uni<Void>
HttpServerFileUpload.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.io.smallrye.mutiny.Uni<Void>
HttpServerRequest.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.io.smallrye.mutiny.Uni<Void>
ServerWebSocket.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.io.smallrye.mutiny.Uni<Void>
WebSocket.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.io.smallrye.mutiny.Uni<Void>
WebSocketBase.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.ClientWebSocket.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.HttpClientResponse.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.HttpServerFileUpload.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.HttpServerRequest.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.ServerWebSocket.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.WebSocket.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.WebSocketBase.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.void
ClientWebSocket.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.void
HttpClientResponse.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.void
HttpServerFileUpload.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.void
HttpServerRequest.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.void
ServerWebSocket.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.void
WebSocket.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.void
WebSocketBase.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.ClientWebSocket.pongHandler
(Consumer<Buffer> handler) ServerWebSocket.pongHandler
(Consumer<Buffer> handler) WebSocket.pongHandler
(Consumer<Buffer> handler) WebSocketBase.pongHandler
(Consumer<Buffer> handler) io.smallrye.mutiny.Uni<HttpClientResponse>
HttpClientRequest.send
(ReadStream<Buffer> body) Send the request with a streambody
.io.smallrye.mutiny.Uni<HttpClientResponse>
HttpClientRequest.send
(Flow.Publisher<Buffer> body) Send the request with a streambody
.io.smallrye.mutiny.Uni<Void>
HttpServerResponse.send
(ReadStream<Buffer> body) Send the request with a streambody
.io.smallrye.mutiny.Uni<Void>
HttpServerResponse.send
(Flow.Publisher<Buffer> body) Send the request with a streambody
.HttpClientRequest.sendAndAwait
(ReadStream<Buffer> body) Blocking variant ofHttpClientRequest.send(io.vertx.mutiny.core.streams.ReadStream)
.HttpClientRequest.sendAndAwait
(Flow.Publisher<Buffer> body) Blocking variant ofHttpClientRequest.send(Flow$Publisher)
.HttpServerResponse.sendAndAwait
(ReadStream<Buffer> body) Blocking variant ofHttpServerResponse.send(io.vertx.mutiny.core.streams.ReadStream)
.HttpServerResponse.sendAndAwait
(Flow.Publisher<Buffer> body) Blocking variant ofHttpServerResponse.send(Flow$Publisher)
.void
HttpClientRequest.sendAndForget
(ReadStream<Buffer> body) Variant ofHttpClientRequest.send(io.vertx.mutiny.core.streams.ReadStream)
that ignores the result of the operation.void
HttpClientRequest.sendAndForget
(Flow.Publisher<Buffer> body) Variant ofHttpClientRequest.send(Flow$Publisher)
that ignores the result of the operation.void
HttpServerResponse.sendAndForget
(ReadStream<Buffer> body) Variant ofHttpServerResponse.send(io.vertx.mutiny.core.streams.ReadStream)
that ignores the result of the operation.void
HttpServerResponse.sendAndForget
(Flow.Publisher<Buffer> body) Variant ofHttpServerResponse.send(Flow$Publisher)
that ignores the result of the operation. -
Uses of Buffer in io.vertx.mutiny.core.net
Methods in io.vertx.mutiny.core.net that return types with arguments of type BufferModifier and TypeMethodDescriptionNetSocket.pipe()
NetSocket.toBlockingIterable()
NetSocket.toBlockingStream()
io.smallrye.mutiny.Multi<Buffer>
NetSocket.toMulti()
NetSocket.toSubscriber()
Methods in io.vertx.mutiny.core.net with parameters of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
Same as but with anhandler
called when the operation completesNetSocket.endAndAwait
(Buffer data) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
.void
NetSocket.endAndForget
(Buffer data) Variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
LikeWriteStream.write(T)
but with anhandler
called when the message has been written or failed to be written.NetSocket.writeAndAwait
(Buffer message) Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.void
NetSocket.writeAndForget
(Buffer message) Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.Method parameters in io.vertx.mutiny.core.net with type arguments of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
NetSocket.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.NetSocket.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.void
NetSocket.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation. -
Uses of Buffer in io.vertx.mutiny.core.parsetools
Methods in io.vertx.mutiny.core.parsetools that return BufferMethods in io.vertx.mutiny.core.parsetools that return types with arguments of type BufferModifier and TypeMethodDescriptionRecordParser.pipe()
RecordParser.toBlockingIterable()
RecordParser.toBlockingStream()
io.smallrye.mutiny.Multi<Buffer>
RecordParser.toMulti()
Methods in io.vertx.mutiny.core.parsetools with parameters of type BufferModifier and TypeMethodDescriptionvoid
void
void
RecordParser.delimitedMode
(Buffer delim) void
void
static RecordParser
RecordParser.newDelimited
(Buffer delim) static RecordParser
RecordParser.newDelimited
(Buffer delim, ReadStream<Buffer> stream) static RecordParser
RecordParser.newDelimited
(Buffer delim, Flow.Publisher<Buffer> stream) static RecordParser
RecordParser.newDelimited
(Buffer delim, Consumer<Buffer> output) Method parameters in io.vertx.mutiny.core.parsetools with type arguments of type BufferModifier and TypeMethodDescriptionstatic RecordParser
RecordParser.newDelimited
(Buffer delim, ReadStream<Buffer> stream) static RecordParser
RecordParser.newDelimited
(Buffer delim, Flow.Publisher<Buffer> stream) static RecordParser
RecordParser.newDelimited
(Buffer delim, Consumer<Buffer> output) static RecordParser
RecordParser.newDelimited
(String delim, ReadStream<Buffer> stream) static RecordParser
RecordParser.newDelimited
(String delim, Flow.Publisher<Buffer> stream) static RecordParser
RecordParser.newDelimited
(String delim, Consumer<Buffer> output) static RecordParser
RecordParser.newFixed
(int size, ReadStream<Buffer> stream) static RecordParser
RecordParser.newFixed
(int size, Flow.Publisher<Buffer> stream) static RecordParser
static JsonParser
JsonParser.newParser
(ReadStream<Buffer> stream) static JsonParser
JsonParser.newParser
(Flow.Publisher<Buffer> stream) io.smallrye.mutiny.Uni<Void>
RecordParser.pipeTo
(WriteStream<Buffer> dst) Pipe thisReadStream
to theWriteStream
.RecordParser.pipeToAndAwait
(WriteStream<Buffer> dst) Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.void
RecordParser.pipeToAndForget
(WriteStream<Buffer> dst) Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.void
-
Uses of Buffer in io.vertx.mutiny.ext.mail
Methods in io.vertx.mutiny.ext.mail that return BufferMethods in io.vertx.mutiny.ext.mail that return types with arguments of type BufferMethods in io.vertx.mutiny.ext.mail with parameters of type BufferMethod parameters in io.vertx.mutiny.ext.mail with type arguments of type BufferModifier and TypeMethodDescriptionMailAttachment.setStream
(ReadStream<Buffer> stream) MailAttachment.setStream
(Flow.Publisher<Buffer> stream) -
Uses of Buffer in io.vertx.mutiny.ext.mongo
Methods in io.vertx.mutiny.ext.mongo that return types with arguments of type BufferModifier and TypeMethodDescriptionMongoGridFsClient.readByFileName
(String fileName) MongoGridFsClient.readByFileNameWithOptions
(String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options) Method parameters in io.vertx.mutiny.ext.mongo with type arguments of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Long>
MongoGridFsClient.downloadByFileName
(WriteStream<Buffer> stream, String fileName) MongoGridFsClient.downloadByFileNameAndAwait
(WriteStream<Buffer> stream, String fileName) MongoGridFsClient.downloadByFileNameAndForget
(WriteStream<Buffer> stream, String fileName) io.smallrye.mutiny.Uni<Long>
MongoGridFsClient.downloadByFileNameWithOptions
(WriteStream<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options) MongoGridFsClient.downloadByFileNameWithOptionsAndAwait
(WriteStream<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options) MongoGridFsClient.downloadByFileNameWithOptionsAndForget
(WriteStream<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options) io.smallrye.mutiny.Uni<Long>
MongoGridFsClient.downloadById
(WriteStream<Buffer> stream, String id) MongoGridFsClient.downloadByIdAndAwait
(WriteStream<Buffer> stream, String id) MongoGridFsClient.downloadByIdAndForget
(WriteStream<Buffer> stream, String id) io.smallrye.mutiny.Uni<String>
MongoGridFsClient.uploadByFileName
(ReadStream<Buffer> stream, String fileName) io.smallrye.mutiny.Uni<String>
MongoGridFsClient.uploadByFileName
(Flow.Publisher<Buffer> stream, String fileName) MongoGridFsClient.uploadByFileNameAndAwait
(ReadStream<Buffer> stream, String fileName) MongoGridFsClient.uploadByFileNameAndAwait
(Flow.Publisher<Buffer> stream, String fileName) MongoGridFsClient.uploadByFileNameAndForget
(ReadStream<Buffer> stream, String fileName) MongoGridFsClient.uploadByFileNameAndForget
(Flow.Publisher<Buffer> stream, String fileName) io.smallrye.mutiny.Uni<String>
MongoGridFsClient.uploadByFileNameWithOptions
(ReadStream<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options) io.smallrye.mutiny.Uni<String>
MongoGridFsClient.uploadByFileNameWithOptions
(Flow.Publisher<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options) MongoGridFsClient.uploadByFileNameWithOptionsAndAwait
(ReadStream<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options) MongoGridFsClient.uploadByFileNameWithOptionsAndAwait
(Flow.Publisher<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options) MongoGridFsClient.uploadByFileNameWithOptionsAndForget
(ReadStream<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options) MongoGridFsClient.uploadByFileNameWithOptionsAndForget
(Flow.Publisher<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options) -
Uses of Buffer in io.vertx.mutiny.ext.stomp
Methods in io.vertx.mutiny.ext.stomp with parameters of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<io.vertx.ext.stomp.Frame>
Sends aSEND
frame to the server to the given destination.io.smallrye.mutiny.Uni<io.vertx.ext.stomp.Frame>
Sends aSEND
frame to the server to the given destination.io.smallrye.mutiny.Uni<io.vertx.ext.stomp.Frame>
Sends aSEND
frame to the server.io.vertx.ext.stomp.Frame
StompClientConnection.sendAndAwait
(String destination, Buffer body) Blocking variant ofStompClientConnection.send(String,io.vertx.mutiny.core.buffer.Buffer)
.io.vertx.ext.stomp.Frame
Blocking variant ofStompClientConnection.send(String,Map,io.vertx.mutiny.core.buffer.Buffer)
.io.vertx.ext.stomp.Frame
StompClientConnection.sendAndAwait
(Map<String, String> headers, Buffer body) Blocking variant ofStompClientConnection.send(Map,io.vertx.mutiny.core.buffer.Buffer)
.StompClientConnection.sendAndForget
(String destination, Buffer body) Variant ofStompClientConnection.send(String,io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.Variant ofStompClientConnection.send(String,Map,io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.StompClientConnection.sendAndForget
(Map<String, String> headers, Buffer body) Variant ofStompClientConnection.send(Map,io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation. -
Uses of Buffer in io.vertx.mutiny.ext.web
Methods in io.vertx.mutiny.ext.web that return BufferModifier and TypeMethodDescriptionRequestBody.buffer()
RoutingContext.getBody()
Deprecated.UseRoutingContext.body()
instead.Methods in io.vertx.mutiny.ext.web with parameters of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
RoutingContext.endAndAwait
(Buffer buffer) Blocking variant ofRoutingContext.end(io.vertx.mutiny.core.buffer.Buffer)
.RoutingContext.endAndForget
(Buffer buffer) Variant ofRoutingContext.end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
Deprecated.This method is internal. -
Uses of Buffer in io.vertx.mutiny.ext.web.client
Methods in io.vertx.mutiny.ext.web.client that return BufferMethods in io.vertx.mutiny.ext.web.client that return types with arguments of type BufferModifier and TypeMethodDescriptionWebClient.delete
(int port, String host, UriTemplate requestURI) WebClient.delete
(UriTemplate requestURI) WebClient.delete
(String host, UriTemplate requestURI) WebClient.deleteAbs
(UriTemplate absoluteURI) WebClient.get
(int port, String host, UriTemplate requestURI) WebClient.get
(UriTemplate requestURI) WebClient.get
(String host, UriTemplate requestURI) WebClient.getAbs
(UriTemplate absoluteURI) WebClient.head
(int port, String host, UriTemplate requestURI) WebClient.head
(UriTemplate requestURI) WebClient.head
(String host, UriTemplate requestURI) WebClient.headAbs
(UriTemplate absoluteURI) WebClient.patch
(int port, String host, UriTemplate requestURI) WebClient.patch
(UriTemplate requestURI) WebClient.patch
(String host, UriTemplate requestURI) WebClient.patchAbs
(UriTemplate absoluteURI) WebClient.post
(int port, String host, UriTemplate requestURI) WebClient.post
(UriTemplate requestURI) WebClient.post
(String host, UriTemplate requestURI) WebClient.postAbs
(UriTemplate absoluteURI) WebClient.put
(int port, String host, UriTemplate requestURI) WebClient.put
(UriTemplate requestURI) WebClient.put
(String host, UriTemplate requestURI) WebClient.putAbs
(UriTemplate absoluteURI) WebClient.request
(io.vertx.core.http.HttpMethod method, int port, String host, UriTemplate requestURI) WebClient.request
(io.vertx.core.http.HttpMethod method, io.vertx.core.http.RequestOptions options) WebClient.request
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, int port, String host, UriTemplate requestURI) WebClient.request
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, int port, String host, String requestURI) WebClient.request
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, io.vertx.core.http.RequestOptions options) WebClient.request
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, UriTemplate requestURI) WebClient.request
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, String requestURI) WebClient.request
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, String host, UriTemplate requestURI) WebClient.request
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, String host, String requestURI) WebClient.request
(io.vertx.core.http.HttpMethod method, UriTemplate requestURI) WebClient.request
(io.vertx.core.http.HttpMethod method, String host, UriTemplate requestURI) WebClient.requestAbs
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, UriTemplate absoluteURI) WebClient.requestAbs
(io.vertx.core.http.HttpMethod method, SocketAddress serverAddress, String absoluteURI) WebClient.requestAbs
(io.vertx.core.http.HttpMethod method, UriTemplate absoluteURI) WebClient.requestAbs
(io.vertx.core.http.HttpMethod method, String absoluteURI) Methods in io.vertx.mutiny.ext.web.client with parameters of type BufferModifier and TypeMethodDescriptionHttpRequest.basicAuthentication
(Buffer id, Buffer password) io.smallrye.mutiny.Uni<HttpResponse<T>>
HttpRequest.sendBuffer
(Buffer body) LikeHttpRequest.send()
but with an HTTP requestbody
buffer.HttpRequest.sendBufferAndAwait
(Buffer body) Blocking variant ofHttpRequest.sendBuffer(io.vertx.mutiny.core.buffer.Buffer)
.void
HttpRequest.sendBufferAndForget
(Buffer body) Variant ofHttpRequest.sendBuffer(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.Method parameters in io.vertx.mutiny.ext.web.client with type arguments of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<HttpResponse<T>>
HttpRequest.sendStream
(ReadStream<Buffer> body) LikeHttpRequest.send()
but with an HTTP requestbody
stream.io.smallrye.mutiny.Uni<HttpResponse<T>>
HttpRequest.sendStream
(Flow.Publisher<Buffer> body) LikeHttpRequest.send()
but with an HTTP requestbody
stream.HttpRequest.sendStreamAndAwait
(ReadStream<Buffer> body) Blocking variant ofHttpRequest.sendStream(io.vertx.mutiny.core.streams.ReadStream)
.HttpRequest.sendStreamAndAwait
(Flow.Publisher<Buffer> body) Blocking variant ofHttpRequest.sendStream(Flow$Publisher)
.void
HttpRequest.sendStreamAndForget
(ReadStream<Buffer> body) Variant ofHttpRequest.sendStream(io.vertx.mutiny.core.streams.ReadStream)
that ignores the result of the operation.void
HttpRequest.sendStreamAndForget
(Flow.Publisher<Buffer> body) Variant ofHttpRequest.sendStream(Flow$Publisher)
that ignores the result of the operation. -
Uses of Buffer in io.vertx.mutiny.ext.web.client.predicate
Methods in io.vertx.mutiny.ext.web.client.predicate that return types with arguments of type Buffer -
Uses of Buffer in io.vertx.mutiny.ext.web.codec
Methods in io.vertx.mutiny.ext.web.codec that return types with arguments of type BufferMethod parameters in io.vertx.mutiny.ext.web.codec with type arguments of type Buffer -
Uses of Buffer in io.vertx.mutiny.ext.web.common.template
Methods in io.vertx.mutiny.ext.web.common.template that return BufferModifier and TypeMethodDescriptionTemplateEngine.renderAndAwait
(io.vertx.core.json.JsonObject context, String templateFileName) Blocking variant ofTemplateEngine.render(JsonObject,String)
.TemplateEngine.renderAndAwait
(Map<String, Object> context, String templateFileName) Blocking variant ofTemplateEngine.render(Map,String)
.Methods in io.vertx.mutiny.ext.web.common.template that return types with arguments of type Buffer -
Uses of Buffer in io.vertx.mutiny.ext.web.handler.sockjs
Methods in io.vertx.mutiny.ext.web.handler.sockjs that return types with arguments of type BufferModifier and TypeMethodDescriptionSockJSSocket.pipe()
SockJSSocket.toBlockingIterable()
SockJSSocket.toBlockingStream()
io.smallrye.mutiny.Multi<Buffer>
SockJSSocket.toMulti()
SockJSSocket.toSubscriber()
Methods in io.vertx.mutiny.ext.web.handler.sockjs with parameters of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
SockJSSocket.endAndAwait
(Buffer data) void
SockJSSocket.endAndForget
(Buffer data) io.smallrye.mutiny.Uni<Void>
SockJSSocket.writeAndAwait
(Buffer data) void
SockJSSocket.writeAndForget
(Buffer data) Method parameters in io.vertx.mutiny.ext.web.handler.sockjs with type arguments of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
SockJSSocket.pipeTo
(WriteStream<Buffer> dst) SockJSSocket.pipeToAndAwait
(WriteStream<Buffer> dst) void
SockJSSocket.pipeToAndForget
(WriteStream<Buffer> dst) -
Uses of Buffer in io.vertx.mutiny.ext.web.multipart
Methods in io.vertx.mutiny.ext.web.multipart that return BufferMethods in io.vertx.mutiny.ext.web.multipart with parameters of type BufferModifier and TypeMethodDescriptionMultipartForm.binaryFileUpload
(String name, String filename, Buffer content, String mediaType) MultipartForm.textFileUpload
(String name, String filename, Buffer content, String mediaType) -
Uses of Buffer in io.vertx.mutiny.ext.web.validation
Methods in io.vertx.mutiny.ext.web.validation that return Buffer -
Uses of Buffer in io.vertx.mutiny.httpproxy
Methods in io.vertx.mutiny.httpproxy that return types with arguments of type BufferMethods in io.vertx.mutiny.httpproxy with parameters of type BufferMethod parameters in io.vertx.mutiny.httpproxy with type arguments of type BufferModifier and TypeMethodDescriptionstatic Body
Body.body
(ReadStream<Buffer> stream) static Body
Body.body
(ReadStream<Buffer> stream, long len) static Body
Body.body
(Flow.Publisher<Buffer> stream) static Body
Body.body
(Flow.Publisher<Buffer> stream, long len) -
Uses of Buffer in io.vertx.mutiny.kafka.client.producer
Methods in io.vertx.mutiny.kafka.client.producer that return BufferMethods in io.vertx.mutiny.kafka.client.producer with parameters of type Buffer -
Uses of Buffer in io.vertx.mutiny.mqtt
Methods in io.vertx.mutiny.mqtt with parameters of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Integer>
MqttClient.publish
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain) Sends the PUBLISH message to the remote MQTT serverio.smallrye.mutiny.Uni<Integer>
MqttEndpoint.publish
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain) Sends the PUBLISH message to the remote MQTT serverio.smallrye.mutiny.Uni<Integer>
MqttEndpoint.publish
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId) Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageIdio.smallrye.mutiny.Uni<Integer>
MqttEndpoint.publish
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, io.netty.handler.codec.mqtt.MqttProperties properties) Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageIdMqttClient.publishAndAwait
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain) MqttEndpoint.publishAndAwait
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain) MqttEndpoint.publishAndAwait
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId) MqttEndpoint.publishAndAwait
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, io.netty.handler.codec.mqtt.MqttProperties properties) MqttClient.publishAndForget
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain) Variant ofMqttClient.publish(String,io.vertx.mutiny.core.buffer.Buffer,MqttQoS,boolean,boolean)
that ignores the result of the operation.MqttEndpoint.publishAndForget
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain) Variant ofMqttEndpoint.publish(String,io.vertx.mutiny.core.buffer.Buffer,MqttQoS,boolean,boolean)
that ignores the result of the operation.MqttEndpoint.publishAndForget
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId) Variant ofMqttEndpoint.publish(String,io.vertx.mutiny.core.buffer.Buffer,MqttQoS,boolean,boolean,int)
that ignores the result of the operation.MqttEndpoint.publishAndForget
(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, io.netty.handler.codec.mqtt.MqttProperties properties) Variant ofMqttEndpoint.publish(String,io.vertx.mutiny.core.buffer.Buffer,MqttQoS,boolean,boolean,int,MqttProperties)
that ignores the result of the operation. -
Uses of Buffer in io.vertx.mutiny.mqtt.messages
Methods in io.vertx.mutiny.mqtt.messages that return Buffer -
Uses of Buffer in io.vertx.mutiny.rabbitmq
Methods in io.vertx.mutiny.rabbitmq that return BufferMethods in io.vertx.mutiny.rabbitmq with parameters of type BufferModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
RabbitMQClient.basicPublish
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message.io.smallrye.mutiny.Uni<Void>
RabbitMQClient.basicPublish
(String exchange, String routingKey, Buffer body) Publish a message.RabbitMQClient.basicPublishAndAwait
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) RabbitMQClient.basicPublishAndAwait
(String exchange, String routingKey, Buffer body) Blocking variant ofRabbitMQClient.basicPublish(String,String,io.vertx.mutiny.core.buffer.Buffer)
.void
RabbitMQClient.basicPublishAndForget
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Variant ofRabbitMQClient.basicPublish(String,String,BasicProperties,io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.void
RabbitMQClient.basicPublishAndForget
(String exchange, String routingKey, Buffer body) Variant ofRabbitMQClient.basicPublish(String,String,io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
RabbitMQClient.basicPublishWithDeliveryTag
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Consumer<Long> deliveryTagHandler) Publish a message.RabbitMQClient.basicPublishWithDeliveryTagAndAwait
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Consumer<Long> deliveryTagHandler) void
RabbitMQClient.basicPublishWithDeliveryTagAndForget
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Consumer<Long> deliveryTagHandler) Variant ofRabbitMQClient.basicPublishWithDeliveryTag(String,String,BasicProperties,io.vertx.mutiny.core.buffer.Buffer,Consumer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
RabbitMQPublisher.publish
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message.RabbitMQPublisher.publishAndAwait
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) void
RabbitMQPublisher.publishAndForget
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Variant ofRabbitMQPublisher.publish(String,String,BasicProperties,io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Long>
RabbitMQPublisher.publishConfirm
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message and complete when publish confirm has returned.RabbitMQPublisher.publishConfirmAndAwait
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) void
RabbitMQPublisher.publishConfirmAndForget
(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Variant ofRabbitMQPublisher.publishConfirm(String,String,BasicProperties,io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation. -
Uses of Buffer in io.vertx.mutiny.redis.client
Methods in io.vertx.mutiny.redis.client that return BufferMethods in io.vertx.mutiny.redis.client with parameters of type Buffer -
Uses of Buffer in io.vertx.mutiny.sqlclient
Methods in io.vertx.mutiny.sqlclient that return BufferMethods in io.vertx.mutiny.sqlclient with parameters of type Buffer