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

Packages that use ReadStream

Package	Description
io.vertx.mutiny.amqp
io.vertx.mutiny.cassandra
io.vertx.mutiny.config
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.mail
io.vertx.mutiny.ext.mongo
io.vertx.mutiny.ext.web.client
io.vertx.mutiny.ext.web.codec
io.vertx.mutiny.ext.web.handler.sockjs
io.vertx.mutiny.httpproxy
io.vertx.mutiny.kafka.client.consumer
io.vertx.mutiny.pgclient.pubsub
io.vertx.mutiny.rabbitmq
io.vertx.mutiny.redis.client
io.vertx.mutiny.sqlclient

Uses of ReadStream in io.vertx.mutiny.amqp

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

Modifier and Type	Class	Description
class	AmqpReceiver	Interface used to consume AMQP message as a stream of message.

Uses of ReadStream in io.vertx.mutiny.cassandra

Classes in io.vertx.mutiny.cassandra that implement ReadStream

Modifier and Type	Class	Description
class	CassandraRowStream	A ReadStream for Row consumption.

Uses of ReadStream in io.vertx.mutiny.config

Methods in io.vertx.mutiny.config that return ReadStream

Modifier and Type	Method	Description
ReadStream<io.vertx.core.json.JsonObject>	ConfigRetriever.configStream()

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

Classes in io.vertx.mutiny.core.eventbus that implement ReadStream

Modifier and Type	Class	Description
class	MessageConsumer<T>	An event bus consumer object representing a stream of message to an EventBus address that can be read from.

Methods in io.vertx.mutiny.core.eventbus that return ReadStream

Modifier and Type	Method	Description
ReadStream<T>	MessageConsumer.bodyStream()

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

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

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

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

Subinterfaces of ReadStream 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 ReadStream

Modifier and Type	Class	Description
class	ClientWebSocket	Represents a client-side WebSocket.
class	HttpClientResponse	Represents a client-side HTTP response.
class	HttpServerFileUpload	Represents an file upload from an HTML FORM.
class	HttpServerRequest	Represents a server-side HTTP request.
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 ReadStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<HttpClientResponse>	HttpClientRequest.send(ReadStream<io.vertx.core.buffer.Buffer> body)	Send the request with a stream body.
io.smallrye.mutiny.Uni<Void>	HttpServerResponse.send(ReadStream<io.vertx.core.buffer.Buffer> body)	Send the request with a stream body.
HttpClientResponse	HttpClientRequest.sendAndAwait(ReadStream<io.vertx.core.buffer.Buffer> body)	Send the request with a stream body.
void	HttpServerResponse.sendAndAwait(ReadStream<io.vertx.core.buffer.Buffer> body)	Send the request with a stream body.
HttpClientRequest	HttpClientRequest.sendAndForget(ReadStream<io.vertx.core.buffer.Buffer> body)	Send the request with a stream body.
HttpServerResponse	HttpServerResponse.sendAndForget(ReadStream<io.vertx.core.buffer.Buffer> body)	Send the request with a stream body.

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

Subinterfaces of ReadStream 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 ReadStream

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

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

Classes in io.vertx.mutiny.core.parsetools that implement ReadStream

Modifier and Type	Class	Description
class	JsonParser	A parser class which allows to incrementally parse json elements and emit json parse events instead of parsing a json element fully.
class	RecordParser	A helper class which allows you to easily parse protocols which are delimited by a sequence of bytes, or fixed size records.

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

Modifier and Type	Method	Description
static RecordParser	RecordParser.newDelimited(io.vertx.core.buffer.Buffer delim, ReadStream<io.vertx.core.buffer.Buffer> stream)	Like RecordParser.newDelimited(Buffer) but wraps the stream.
static RecordParser	RecordParser.newDelimited(String delim, ReadStream<io.vertx.core.buffer.Buffer> stream)	Like RecordParser.newDelimited(String) but wraps the stream.
static RecordParser	RecordParser.newFixed(int size, ReadStream<io.vertx.core.buffer.Buffer> stream)	Like RecordParser.newFixed(int) but wraps the stream.
static JsonParser	JsonParser.newParser(ReadStream<io.vertx.core.buffer.Buffer> stream)	Create a new JsonParser instance.

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

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

Modifier and Type	Class	Description
static class	ReadStream.ReadStreamImpl<T>

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

Modifier and Type	Method	Description
ReadStream<T>	ReadStream.endHandler(Runnable endHandler)	Set an end handler.
ReadStream<T>	ReadStream.exceptionHandler(Consumer<Throwable> handler)	Set an exception handler on the read stream.
ReadStream<T>	ReadStream.ReadStreamImpl.exceptionHandler(Consumer<Throwable> handler)	Set an exception handler on the read stream.
ReadStream<T>	ReadStream.fetch(long amount)	Fetch the specified amount of elements.
ReadStream<T>	ReadStream.handler(Consumer<T> handler)	Set a data handler.
static <T> ReadStream<T>	ReadStream.newInstance(io.vertx.core.streams.ReadStream<T> delegate)	Creates a new instance of the ReadStream.
static <T> ReadStream<T>	ReadStream.newInstance(io.vertx.core.streams.ReadStream<T> delegate, TypeArg<T> typeArg_0)	Creates a new instance of the ReadStream.
ReadStream<T>	ReadStream.pause()	Pause the ReadStream, it sets the buffer in fetch mode and clears the actual demand.
ReadStream<T>	ReadStream.resume()	Resume reading, and sets the buffer in flowing mode.

Uses of ReadStream in io.vertx.mutiny.ext.mail

Methods in io.vertx.mutiny.ext.mail that return ReadStream

Modifier and Type	Method	Description
ReadStream<io.vertx.core.buffer.Buffer>	MailAttachment.getStream()	Gets the data stream.

Methods in io.vertx.mutiny.ext.mail with parameters of type ReadStream

Modifier and Type	Method	Description
MailAttachment	MailAttachment.setStream(ReadStream<io.vertx.core.buffer.Buffer> stream)	Sets the data stream.

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

Methods in io.vertx.mutiny.ext.mongo that return ReadStream

Modifier and Type	Method	Description
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.aggregate(String collection, io.vertx.core.json.JsonArray pipeline)	Run aggregate MongoDB command with default AggregateOptions.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.aggregateWithOptions(String collection, io.vertx.core.json.JsonArray pipeline, io.vertx.ext.mongo.AggregateOptions options)	Run aggregate MongoDB command.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.distinctBatch(String collection, String fieldName, String resultClassname)	Gets the distinct values of the specified field name.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.distinctBatch(String collection, String fieldName, String resultClassname, io.vertx.ext.mongo.DistinctOptions distinctOptions)	Gets the distinct values of the specified field name.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.distinctBatchWithQuery(String collection, String fieldName, String resultClassname, io.vertx.core.json.JsonObject query)	Gets the distinct values of the specified field name filtered by specified query.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.distinctBatchWithQuery(String collection, String fieldName, String resultClassname, io.vertx.core.json.JsonObject query, int batchSize)	Gets the distinct values of the specified field name filtered by specified query.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.distinctBatchWithQuery(String collection, String fieldName, String resultClassname, io.vertx.core.json.JsonObject query, int batchSize, io.vertx.ext.mongo.DistinctOptions distinctOptions)	Gets the distinct values of the specified field name filtered by specified query.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.distinctBatchWithQuery(String collection, String fieldName, String resultClassname, io.vertx.core.json.JsonObject query, io.vertx.ext.mongo.DistinctOptions distinctOptions)	Gets the distinct values of the specified field name filtered by specified query.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.findBatch(String collection, io.vertx.core.json.JsonObject query)	Find matching documents in the specified collection.
ReadStream<io.vertx.core.json.JsonObject>	MongoClient.findBatchWithOptions(String collection, io.vertx.core.json.JsonObject query, io.vertx.ext.mongo.FindOptions options)	Find matching documents in the specified collection, specifying options.
ReadStream<io.vertx.core.buffer.Buffer>	MongoGridFsClient.readByFileName(String fileName)	Read file by name to ReadStream
ReadStream<io.vertx.core.buffer.Buffer>	MongoGridFsClient.readByFileNameWithOptions(String fileName, io.vertx.ext.mongo.GridFsDownloadOptions options)	Read file by name to ReadStream with options
ReadStream<io.vertx.core.buffer.Buffer>	MongoGridFsClient.readById(String id)	Read file by id to ReadStream
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<io.vertx.core.json.JsonObject>>	MongoClient.watch(String collection, io.vertx.core.json.JsonArray pipeline, boolean withUpdatedDoc, int batchSize)	Watch the collection change.

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

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<String>	MongoGridFsClient.uploadByFileName(ReadStream<io.vertx.core.buffer.Buffer> stream, String fileName)	Unlike the bare Vert.x variant, this method returns a Uni.
String	MongoGridFsClient.uploadByFileNameAndAwait(ReadStream<io.vertx.core.buffer.Buffer> stream, String fileName)	Unlike the bare Vert.x variant, this method returns a String.
MongoGridFsClient	MongoGridFsClient.uploadByFileNameAndForget(ReadStream<io.vertx.core.buffer.Buffer> stream, String fileName)	Unlike the bare Vert.x variant, this method ignores the String result or any failure.
io.smallrye.mutiny.Uni<String>	MongoGridFsClient.uploadByFileNameWithOptions(ReadStream<io.vertx.core.buffer.Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options)	Unlike the bare Vert.x variant, this method returns a Uni.
String	MongoGridFsClient.uploadByFileNameWithOptionsAndAwait(ReadStream<io.vertx.core.buffer.Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options)	Unlike the bare Vert.x variant, this method returns a String.
MongoGridFsClient	MongoGridFsClient.uploadByFileNameWithOptionsAndForget(ReadStream<io.vertx.core.buffer.Buffer> stream, String fileName, io.vertx.ext.mongo.GridFsUploadOptions options)	Unlike the bare Vert.x variant, this method ignores the String result or any failure.

Uses of ReadStream in io.vertx.mutiny.ext.web.client

Methods in io.vertx.mutiny.ext.web.client with parameters of type ReadStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<HttpResponse<T>>	HttpRequest.sendStream(ReadStream<io.vertx.core.buffer.Buffer> body)	Like HttpRequest.send() but with an HTTP request body stream.
HttpResponse<T>	HttpRequest.sendStreamAndAwait(ReadStream<io.vertx.core.buffer.Buffer> body)	Like HttpRequest.send() but with an HTTP request body stream.
HttpRequest<T>	HttpRequest.sendStreamAndForget(ReadStream<io.vertx.core.buffer.Buffer> body)	Like HttpRequest.send() but with an HTTP request body stream.

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

Method parameters in io.vertx.mutiny.ext.web.codec with type arguments of type ReadStream

Modifier and Type	Method	Description
static BodyCodec<Void>	BodyCodec.sseStream(Consumer<ReadStream<io.vertx.ext.web.codec.SseEvent>> handler)	A body codec that parse the response as a Server-SentEvent stream.

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

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

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

Uses of ReadStream in io.vertx.mutiny.httpproxy

Methods in io.vertx.mutiny.httpproxy that return ReadStream

Modifier and Type	Method	Description
ReadStream<io.vertx.core.buffer.Buffer>	Body.stream()	Get stream of the Body.

Methods in io.vertx.mutiny.httpproxy with parameters of type ReadStream

Modifier and Type	Method	Description
static Body	Body.body(ReadStream<io.vertx.core.buffer.Buffer> stream)	Create a new Body instance.
static Body	Body.body(ReadStream<io.vertx.core.buffer.Buffer> stream, long len)	Create a new Body instance.
static Body	Body.body(ReadStream<io.vertx.core.buffer.Buffer> stream, long len, io.vertx.httpproxy.MediaType mediatype)
static Body	Body.body(ReadStream<io.vertx.core.buffer.Buffer> stream, long len, String mediatype)

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

Classes in io.vertx.mutiny.kafka.client.consumer that implement ReadStream

Modifier and Type	Class	Description
class	KafkaConsumer<K,V>	Vert.x Kafka consumer.

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

Classes in io.vertx.mutiny.pgclient.pubsub that implement ReadStream

Modifier and Type	Class	Description
class	PgChannel	A channel to Postgres that tracks the subscription to a given Postgres channel using the LISTEN/UNLISTEN commands.

Uses of ReadStream in io.vertx.mutiny.rabbitmq

Classes in io.vertx.mutiny.rabbitmq that implement ReadStream

Modifier and Type	Class	Description
class	RabbitMQConsumer	A stream of messages from a rabbitmq queue.

Methods in io.vertx.mutiny.rabbitmq that return ReadStream

Modifier and Type	Method	Description
ReadStream<io.vertx.rabbitmq.RabbitMQConfirmation>	RabbitMQClient.addConfirmListenerAndAwait(int maxQueueSize)	Add a Confirm Listener to the channel.
ReadStream<io.vertx.rabbitmq.RabbitMQPublisherConfirmation>	RabbitMQPublisher.getConfirmationStream()	Get the ReadStream that contains the message IDs for confirmed messages.

Methods in io.vertx.mutiny.rabbitmq that return types with arguments of type ReadStream

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<ReadStream<io.vertx.rabbitmq.RabbitMQConfirmation>>	RabbitMQClient.addConfirmListener(int maxQueueSize)	Add a Confirm Listener to the channel.

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

Classes in io.vertx.mutiny.redis.client that implement ReadStream

Modifier and Type	Class	Description
class	RedisConnection	A simple Redis client.

Uses of ReadStream in io.vertx.mutiny.sqlclient

Classes in io.vertx.mutiny.sqlclient that implement ReadStream

Modifier and Type	Class	Description
class	RowStream<T>	A row oriented stream.