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
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.sql
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 that return WriteStream

Modifier and Type	Method	Description
WriteStream<AmqpMessage>	AmqpSender.drainHandler(Runnable arg0)

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)
Void	AmqpReceiver.pipeToAndAwait(WriteStream<AmqpMessage> dst)
void	AmqpReceiver.pipeToAndForget(WriteStream<AmqpMessage> dst)

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)
Void	CassandraRowStream.pipeToAndAwait(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)
void	CassandraRowStream.pipeToAndForget(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)

Uses of WriteStream in io.vertx.mutiny.core

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

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	TimeoutStream.pipeTo(WriteStream<Long> dst)	Deprecated.
Void	TimeoutStream.pipeToAndAwait(WriteStream<Long> dst)	Deprecated.
void	TimeoutStream.pipeToAndForget(WriteStream<Long> dst)	Deprecated.

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<Buffer>	DatagramSocket.sender(int port, String host)

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

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	DatagramSocket.pipeTo(WriteStream<DatagramPacket> dst)	Pipe this ReadStream to the WriteStream.
Void	DatagramSocket.pipeToAndAwait(WriteStream<DatagramPacket> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
void	DatagramSocket.pipeToAndForget(WriteStream<DatagramPacket> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.

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>> dst)	Pipe this ReadStream to the WriteStream.
Void	MessageConsumer.pipeToAndAwait(WriteStream<Message<T>> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
void	MessageConsumer.pipeToAndForget(WriteStream<Message<T>> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.

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<Buffer> dst)	Pipe this ReadStream to the WriteStream.
Void	AsyncFile.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
void	AsyncFile.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.

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 initially not connected.
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	Represents a client-side WebSocket.

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<Buffer> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	HttpClientResponse.pipeTo(WriteStream<Buffer> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	HttpServerFileUpload.pipeTo(WriteStream<Buffer> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	HttpServerRequest.pipeTo(WriteStream<Buffer> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	ServerWebSocket.pipeTo(WriteStream<Buffer> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	WebSocket.pipeTo(WriteStream<Buffer> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	WebSocketBase.pipeTo(WriteStream<Buffer> dst)	Pipe this ReadStream to the WriteStream.
Void	ClientWebSocket.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
Void	HttpClientResponse.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
Void	HttpServerFileUpload.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
Void	HttpServerRequest.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
Void	ServerWebSocket.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
Void	WebSocket.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
Void	WebSocketBase.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
void	ClientWebSocket.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.
void	HttpClientResponse.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.
void	HttpServerFileUpload.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.
void	HttpServerRequest.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.
void	ServerWebSocket.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.
void	WebSocket.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.
void	WebSocketBase.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.

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

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.

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<Buffer> dst)	Pipe this ReadStream to the WriteStream.
Void	NetSocket.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
void	NetSocket.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.

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<JsonEvent> dst)	Pipe this ReadStream to the WriteStream.
io.smallrye.mutiny.Uni<Void>	RecordParser.pipeTo(WriteStream<Buffer> dst)	Pipe this ReadStream to the WriteStream.
Void	JsonParser.pipeToAndAwait(WriteStream<JsonEvent> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
Void	RecordParser.pipeToAndAwait(WriteStream<Buffer> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
void	JsonParser.pipeToAndForget(WriteStream<JsonEvent> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.
void	RecordParser.pipeToAndForget(WriteStream<Buffer> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.

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

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

Modifier and Type	Method	Description
WriteStream<T>	WriteStream.drainHandler(Runnable handler)
WriteStream<T>	WriteStream.exceptionHandler(Consumer<Throwable> handler)
static <T> WriteStream<T>	WriteStream.newInstance(io.vertx.core.streams.WriteStream arg)
static <T> WriteStream<T>	WriteStream.newInstance(io.vertx.core.streams.WriteStream arg, TypeArg<T> __typeArg_T)
WriteStream<T>	WriteStream.setWriteQueueMaxSize(int 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.
Void	ReadStream.pipeToAndAwait(WriteStream<T> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
void	ReadStream.pipeToAndForget(WriteStream<T> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.
static <T> Pump	Pump.pump(ReadStream<T> rs, WriteStream<T> ws)	Deprecated.
static <T> Pump	Pump.pump(ReadStream<T> rs, WriteStream<T> ws, int writeQueueMaxSize)	Deprecated.
static <T> Pump	Pump.pump(Flow.Publisher<T> rs, WriteStream<T> ws)	Deprecated.
static <T> Pump	Pump.pump(Flow.Publisher<T> rs, WriteStream<T> ws, int writeQueueMaxSize)	Deprecated.
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)	Blocking variant of Pipe.to(io.vertx.mutiny.core.streams.WriteStream).
void	Pipe.toAndForget(WriteStream<T> dst)	Variant of Pipe.to(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.

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<Buffer> stream, String fileName)
Long	MongoGridFsClient.downloadByFileNameAndAwait(WriteStream<Buffer> stream, String fileName)
MongoGridFsClient	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)
Long	MongoGridFsClient.downloadByFileNameWithOptionsAndAwait(WriteStream<Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options)
MongoGridFsClient	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)
Long	MongoGridFsClient.downloadByIdAndAwait(WriteStream<Buffer> stream, String id)
MongoGridFsClient	MongoGridFsClient.downloadByIdAndForget(WriteStream<Buffer> stream, String id)

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

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

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	SQLRowStream.pipeTo(WriteStream<io.vertx.core.json.JsonArray> dst)
Void	SQLRowStream.pipeToAndAwait(WriteStream<io.vertx.core.json.JsonArray> dst)
void	SQLRowStream.pipeToAndForget(WriteStream<io.vertx.core.json.JsonArray> dst)

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<Buffer> stream)
static BodyCodec<Void>	BodyCodec.pipe(WriteStream<Buffer> stream, boolean close)

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<Buffer> dst)
Void	SockJSSocket.pipeToAndAwait(WriteStream<Buffer> dst)
void	SockJSSocket.pipeToAndForget(WriteStream<Buffer> dst)

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)
Void	KafkaConsumer.pipeToAndAwait(WriteStream<KafkaConsumerRecord<K,V>> dst)
void	KafkaConsumer.pipeToAndForget(WriteStream<KafkaConsumerRecord<K,V>> dst)

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)
Void	PgChannel.pipeToAndAwait(WriteStream<String> dst)
void	PgChannel.pipeToAndForget(WriteStream<String> dst)

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)
Void	RabbitMQConsumer.pipeToAndAwait(WriteStream<RabbitMQMessage> dst)
void	RabbitMQConsumer.pipeToAndForget(WriteStream<RabbitMQMessage> dst)

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<Response> dst)
Void	RedisConnection.pipeToAndAwait(WriteStream<Response> dst)
void	RedisConnection.pipeToAndForget(WriteStream<Response> dst)

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)
Void	RowStream.pipeToAndAwait(WriteStream<T> dst)
void	RowStream.pipeToAndForget(WriteStream<T> dst)