Uses of Interface
io.vertx.mutiny.core.streams.WriteStream

Packages that use WriteStream

Package	Description
io.vertx.mutiny.amqp
io.vertx.mutiny.cassandra
io.vertx.mutiny.core.datagram
io.vertx.mutiny.core.eventbus
io.vertx.mutiny.core.file
io.vertx.mutiny.core.http
io.vertx.mutiny.core.net
io.vertx.mutiny.core.parsetools
io.vertx.mutiny.core.streams
io.vertx.mutiny.ext.mongo
io.vertx.mutiny.ext.web.codec
io.vertx.mutiny.ext.web.handler.sockjs
io.vertx.mutiny.kafka.client.consumer
io.vertx.mutiny.kafka.client.producer
io.vertx.mutiny.pgclient.pubsub
io.vertx.mutiny.rabbitmq
io.vertx.mutiny.redis.client
io.vertx.mutiny.sqlclient

Uses of WriteStream in io.vertx.mutiny.amqp

Classes in io.vertx.mutiny.amqp that implement WriteStream

Modifier and Type	Class	Description
class	AmqpSender	AMQP Sender interface used to send messages.

Methods in io.vertx.mutiny.amqp with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	AmqpReceiver.pipeTo(WriteStream<AmqpMessage> dst)	Pipe this ReadStream to the WriteStream.
void	AmqpReceiver.pipeToAndAwait(WriteStream<AmqpMessage> dst)	Pipe this ReadStream to the WriteStream.
AmqpReceiver	AmqpReceiver.pipeToAndForget(WriteStream<AmqpMessage> dst)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.cassandra

Methods in io.vertx.mutiny.cassandra with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	CassandraRowStream.pipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)	Unlike the bare Vert.x variant, this method returns a Uni.
void	CassandraRowStream.pipeToAndAwait(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)	Unlike the bare Vert.x variant, this method returns a Void.
CassandraRowStream	CassandraRowStream.pipeToAndForget(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)	Unlike the bare Vert.x variant, this method ignores the Void result or any failure.

Uses of WriteStream in io.vertx.mutiny.core.datagram

Methods in io.vertx.mutiny.core.datagram that return WriteStream

Modifier and Type	Method	Description
WriteStream<io.vertx.core.buffer.Buffer>	DatagramSocket.sender(int port, String host)	Returns a WriteStream<Buffer> able to send Buffer to the SocketAddress.

Uses of WriteStream in io.vertx.mutiny.core.eventbus

Methods in io.vertx.mutiny.core.eventbus with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	MessageConsumer.pipeTo(WriteStream<Message<T>> arg0)	Pipe this ReadStream to the WriteStream.
void	MessageConsumer.pipeToAndAwait(WriteStream<Message<T>> arg0)	Pipe this ReadStream to the WriteStream.
MessageConsumer<T>	MessageConsumer.pipeToAndForget(WriteStream<Message<T>> arg0)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.core.file

Classes in io.vertx.mutiny.core.file that implement WriteStream

Modifier and Type	Class	Description
class	AsyncFile	Represents a file on the file-system which can be read from, or written to asynchronously.

Methods in io.vertx.mutiny.core.file with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	AsyncFile.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	AsyncFile.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
AsyncFile	AsyncFile.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.core.http

Subinterfaces of WriteStream in io.vertx.mutiny.core.http

Modifier and Type	Interface	Description
interface	WebSocketBase	Base WebSocket implementation.

Classes in io.vertx.mutiny.core.http that implement WriteStream

Modifier and Type	Class	Description
class	ClientWebSocket	Represents a client-side WebSocket.
class	HttpClientRequest	Represents a client-side HTTP request.
class	HttpServerResponse	Represents a server-side HTTP response.
class	ServerWebSocket	Represents a server side WebSocket.
class	WebSocket	Common WebSocket implementation.
static class	WebSocketBase.WebSocketBaseImpl

Methods in io.vertx.mutiny.core.http with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	ClientWebSocket.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	HttpClientResponse.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	HttpServerFileUpload.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	HttpServerRequest.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	ServerWebSocket.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	WebSocket.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	WebSocketBase.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	WebSocketBase.WebSocketBaseImpl.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	ClientWebSocket.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	HttpClientResponse.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	HttpServerFileUpload.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	HttpServerRequest.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	ServerWebSocket.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	WebSocket.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	WebSocketBase.WebSocketBaseImpl.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
ClientWebSocket	ClientWebSocket.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
HttpClientResponse	HttpClientResponse.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
HttpServerFileUpload	HttpServerFileUpload.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
HttpServerRequest	HttpServerRequest.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
ServerWebSocket	ServerWebSocket.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
WebSocket	WebSocket.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
WebSocketBase.WebSocketBaseImpl	WebSocketBase.WebSocketBaseImpl.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.core.net

Subinterfaces of WriteStream in io.vertx.mutiny.core.net

Modifier and Type	Interface	Description
interface	StreamChannel	Represents a channel interface modelling a duplex flow controlled byte oriented stream.

Classes in io.vertx.mutiny.core.net that implement WriteStream

Modifier and Type	Class	Description
class	NetSocket	Represents a socket-like interface to a TCP connection on either the client or the server side.
class	QuicStream	A Quic stream.
static class	StreamChannel.StreamChannelImpl

Methods in io.vertx.mutiny.core.net with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	NetSocket.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	QuicStream.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	StreamChannel.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	StreamChannel.StreamChannelImpl.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	NetSocket.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	QuicStream.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	StreamChannel.StreamChannelImpl.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
NetSocket	NetSocket.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
QuicStream	QuicStream.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
StreamChannel.StreamChannelImpl	StreamChannel.StreamChannelImpl.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.core.parsetools

Methods in io.vertx.mutiny.core.parsetools with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	JsonParser.pipeTo(WriteStream<io.vertx.core.parsetools.JsonEvent> arg0)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	RecordParser.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
void	JsonParser.pipeToAndAwait(WriteStream<io.vertx.core.parsetools.JsonEvent> arg0)	Pipe this ReadStream to the WriteStream.
void	RecordParser.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.
JsonParser	JsonParser.pipeToAndForget(WriteStream<io.vertx.core.parsetools.JsonEvent> arg0)	Pipe this ReadStream to the WriteStream.
RecordParser	RecordParser.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.core.streams

Classes in io.vertx.mutiny.core.streams that implement WriteStream

Modifier and Type	Class	Description
static class	WriteStream.WriteStreamImpl<T>

Methods in io.vertx.mutiny.core.streams that return WriteStream

Modifier and Type	Method	Description
WriteStream<T>	WriteStream.drainHandler(Runnable handler)	Set a drain handler on the stream.
WriteStream<T>	WriteStream.exceptionHandler(Consumer<Throwable> handler)	Set an exception handler on the write stream.
WriteStream<T>	WriteStream.WriteStreamImpl.exceptionHandler(Consumer<Throwable> handler)	Set an exception handler on the write stream.
static <T> WriteStream<T>	WriteStream.newInstance(io.vertx.core.streams.WriteStream<T> delegate)	Creates a new instance of the WriteStream.
static <T> WriteStream<T>	WriteStream.newInstance(io.vertx.core.streams.WriteStream<T> delegate, TypeArg<T> typeArg_0)	Creates a new instance of the WriteStream.
WriteStream<T>	WriteStream.setWriteQueueMaxSize(int maxSize)	Set the maximum size of the write queue to maxSize.

Methods in io.vertx.mutiny.core.streams with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	ReadStream.pipeTo(WriteStream<T> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	ReadStream.ReadStreamImpl.pipeTo(WriteStream<T> dst)	Pipe this ReadStream to the WriteStream.
void	ReadStream.ReadStreamImpl.pipeToAndAwait(WriteStream<T> dst)	Pipe this ReadStream to the WriteStream.
ReadStream.ReadStreamImpl<T>	ReadStream.ReadStreamImpl.pipeToAndForget(WriteStream<T> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	Pipe.to(WriteStream<T> dst)	Start to pipe the elements to the destination WriteStream.
void	Pipe.toAndAwait(WriteStream<T> dst)	Start to pipe the elements to the destination WriteStream.
Pipe<T>	Pipe.toAndForget(WriteStream<T> dst)	Start to pipe the elements to the destination WriteStream.

Uses of WriteStream in io.vertx.mutiny.ext.mongo

Methods in io.vertx.mutiny.ext.mongo with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Long>	MongoGridFsClient.downloadByFileName(WriteStream<io.vertx.core.buffer.Buffer> stream, String fileName)	Unlike the bare Vert.x variant, this method returns a Uni.
Long	MongoGridFsClient.downloadByFileNameAndAwait(WriteStream<io.vertx.core.buffer.Buffer> stream, String fileName)	Unlike the bare Vert.x variant, this method returns a Long.
MongoGridFsClient	MongoGridFsClient.downloadByFileNameAndForget(WriteStream<io.vertx.core.buffer.Buffer> stream, String fileName)	Unlike the bare Vert.x variant, this method ignores the Long result or any failure.
io.smallrye.mutiny.Uni<Long>	MongoGridFsClient.downloadByFileNameWithOptions(WriteStream<io.vertx.core.buffer.Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options)	Unlike the bare Vert.x variant, this method returns a Uni.
Long	MongoGridFsClient.downloadByFileNameWithOptionsAndAwait(WriteStream<io.vertx.core.buffer.Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options)	Unlike the bare Vert.x variant, this method returns a Long.
MongoGridFsClient	MongoGridFsClient.downloadByFileNameWithOptionsAndForget(WriteStream<io.vertx.core.buffer.Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options)	Unlike the bare Vert.x variant, this method ignores the Long result or any failure.
io.smallrye.mutiny.Uni<Long>	MongoGridFsClient.downloadById(WriteStream<io.vertx.core.buffer.Buffer> stream, String id)	Unlike the bare Vert.x variant, this method returns a Uni.
Long	MongoGridFsClient.downloadByIdAndAwait(WriteStream<io.vertx.core.buffer.Buffer> stream, String id)	Unlike the bare Vert.x variant, this method returns a Long.
MongoGridFsClient	MongoGridFsClient.downloadByIdAndForget(WriteStream<io.vertx.core.buffer.Buffer> stream, String id)	Unlike the bare Vert.x variant, this method ignores the Long result or any failure.

Uses of WriteStream in io.vertx.mutiny.ext.web.codec

Methods in io.vertx.mutiny.ext.web.codec with parameters of type WriteStream

Modifier and Type	Method	Description
static BodyCodec<Void>	BodyCodec.pipe(WriteStream<io.vertx.core.buffer.Buffer> stream)	A body codec that pipes the body to a write stream.
static BodyCodec<Void>	BodyCodec.pipe(WriteStream<io.vertx.core.buffer.Buffer> stream, boolean close)	A body codec that pipes the body to a write stream.

Uses of WriteStream in io.vertx.mutiny.ext.web.handler.sockjs

Classes in io.vertx.mutiny.ext.web.handler.sockjs that implement WriteStream

Modifier and Type	Class	Description
class	SockJSSocket	You interact with SockJS clients through instances of SockJS socket.

Methods in io.vertx.mutiny.ext.web.handler.sockjs with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	SockJSSocket.pipeTo(WriteStream<io.vertx.core.buffer.Buffer> dst)	Pipe this ReadStream to the WriteStream.
void	SockJSSocket.pipeToAndAwait(WriteStream<io.vertx.core.buffer.Buffer> dst)	Pipe this ReadStream to the WriteStream.
SockJSSocket	SockJSSocket.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> dst)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.kafka.client.consumer

Methods in io.vertx.mutiny.kafka.client.consumer with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	KafkaConsumer.pipeTo(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.
void	KafkaConsumer.pipeToAndAwait(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.
KafkaConsumer<K,V>	KafkaConsumer.pipeToAndForget(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.kafka.client.producer

Classes in io.vertx.mutiny.kafka.client.producer that implement WriteStream

Modifier and Type	Class	Description
class	KafkaProducer<K,V>	Vert.x Kafka producer.

Uses of WriteStream in io.vertx.mutiny.pgclient.pubsub

Methods in io.vertx.mutiny.pgclient.pubsub with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	PgChannel.pipeTo(WriteStream<String> dst)	Pipe this ReadStream to the WriteStream.
void	PgChannel.pipeToAndAwait(WriteStream<String> dst)	Pipe this ReadStream to the WriteStream.
PgChannel	PgChannel.pipeToAndForget(WriteStream<String> dst)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.rabbitmq

Methods in io.vertx.mutiny.rabbitmq with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	RabbitMQConsumer.pipeTo(WriteStream<RabbitMQMessage> dst)	Pipe this ReadStream to the WriteStream.
void	RabbitMQConsumer.pipeToAndAwait(WriteStream<RabbitMQMessage> dst)	Pipe this ReadStream to the WriteStream.
RabbitMQConsumer	RabbitMQConsumer.pipeToAndForget(WriteStream<RabbitMQMessage> dst)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.redis.client

Methods in io.vertx.mutiny.redis.client with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	RedisConnection.pipeTo(WriteStream<io.vertx.redis.client.Response> dst)	Pipe this ReadStream to the WriteStream.
void	RedisConnection.pipeToAndAwait(WriteStream<io.vertx.redis.client.Response> dst)	Pipe this ReadStream to the WriteStream.
RedisConnection	RedisConnection.pipeToAndForget(WriteStream<io.vertx.redis.client.Response> dst)	Pipe this ReadStream to the WriteStream.

Uses of WriteStream in io.vertx.mutiny.sqlclient

Methods in io.vertx.mutiny.sqlclient with parameters of type WriteStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	RowStream.pipeTo(WriteStream<T> dst)	Pipe this ReadStream to the WriteStream.
void	RowStream.pipeToAndAwait(WriteStream<T> dst)	Pipe this ReadStream to the WriteStream.
RowStream<T>	RowStream.pipeToAndForget(WriteStream<T> dst)	Pipe this ReadStream to the WriteStream.