Uses of Interface io.vertx.core.streams.ReadStream (Vert.x Stack

Packages that use ReadStream
Package	Description
io.vertx.amqp
io.vertx.cassandra
io.vertx.config
io.vertx.core.eventbus
io.vertx.core.file
io.vertx.core.http
io.vertx.core.net
io.vertx.core.parsetools
io.vertx.core.streams
io.vertx.ext.cluster.infinispan
io.vertx.ext.mail
io.vertx.ext.mail.mailencoder
io.vertx.ext.mongo
io.vertx.ext.reactivestreams
io.vertx.ext.unit.report
io.vertx.ext.web
io.vertx.ext.web.client
io.vertx.ext.web.handler.sockjs
io.vertx.grpc.client
io.vertx.grpc.common
io.vertx.grpc.server
io.vertx.grpc.stub
io.vertx.httpproxy
io.vertx.kafka.client.consumer
io.vertx.pgclient.pubsub
io.vertx.rabbitmq
io.vertx.reactivex
io.vertx.reactivex.core.streams
io.vertx.redis.client
io.vertx.rxjava3
io.vertx.rxjava3.core.streams
io.vertx.sqlclient

Uses of ReadStream in io.vertx.amqp

Subinterfaces of ReadStream in io.vertx.amqp
Modifier and Type Interface Description

interface AmqpReceiver
Interface used to consume AMQP message as a stream of message.
Uses of ReadStream in io.vertx.cassandra

Subinterfaces of ReadStream in io.vertx.cassandra
Modifier and Type Interface Description

interface CassandraRowStream
A ReadStream for Row consumption.
Uses of ReadStream in io.vertx.config

Methods in io.vertx.config that return ReadStream
Modifier and Type Method Description

ReadStream<JsonObject> ConfigRetriever.configStream()

Subinterfaces of ReadStream in io.vertx.amqp
Modifier and Type	Interface	Description
`interface`	`AmqpReceiver`	Interface used to consume AMQP message as a stream of message.

Subinterfaces of ReadStream in io.vertx.cassandra
Modifier and Type	Interface	Description
`interface`	`CassandraRowStream`	A `ReadStream` for `Row` consumption.

Methods in io.vertx.config that return ReadStream
Modifier and Type	Method	Description
`ReadStream<JsonObject>`	ConfigRetriever.`configStream()`

Uses of ReadStream in io.vertx.core.eventbus

Subinterfaces of ReadStream in io.vertx.core.eventbus
Modifier and Type	Interface	Description
`interface`	`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.core.eventbus that return ReadStream
Modifier and Type	Method	Description
`ReadStream<T>`	MessageConsumer.`bodyStream()`

Uses of ReadStream in io.vertx.core.file

Subinterfaces of ReadStream in io.vertx.core.file
Modifier and Type	Interface	Description
`interface`	`AsyncFile`	Represents a file on the file-system which can be read from, or written to asynchronously.

Uses of ReadStream in io.vertx.core.http

Subinterfaces of ReadStream in io.vertx.core.http
Modifier and Type	Interface	Description
`interface`	`ClientWebSocket`	Represents a client-side WebSocket.
`interface`	`HttpClientResponse`	Represents a client-side HTTP response.
`interface`	`HttpServerFileUpload`	Represents an file upload from an HTML FORM.
`interface`	`HttpServerRequest`	Represents a server-side HTTP request.
`interface`	`ServerWebSocket`	Represents a server side WebSocket.
`interface`	`WebSocket`	Common WebSocket implementation.
`interface`	`WebSocketBase`	Base WebSocket implementation.

Methods in io.vertx.core.http with parameters of type ReadStream
Modifier and Type	Method	Description
`default Future<HttpClientResponse>`	HttpClientRequest.`send(ReadStream<Buffer> body)`	Send the request with a stream `body`.
`default Future<Void>`	HttpServerResponse.`send(ReadStream<Buffer> body)`	Send the request with a stream `body`.

Uses of ReadStream in io.vertx.core.net

Subinterfaces of ReadStream in io.vertx.core.net
Modifier and Type	Interface	Description
`interface`	`NetSocket`	Represents a socket-like interface to a TCP connection on either the client or the server side.

Uses of ReadStream in io.vertx.core.parsetools

Subinterfaces of ReadStream in io.vertx.core.parsetools
Modifier and Type	Interface	Description
`interface`	`JsonParser`	A parser class which allows to incrementally parse json elements and emit json parse events instead of parsing a json element fully.
`interface`	`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.core.parsetools with parameters of type ReadStream
Modifier and Type	Method	Description
`static RecordParser`	RecordParser.`newDelimited(Buffer delim, ReadStream<Buffer> stream)`	Like `RecordParser.newDelimited(Buffer)` but wraps the `stream`.
`static RecordParser`	RecordParser.`newDelimited(String delim, ReadStream<Buffer> stream)`	Like `RecordParser.newDelimited(String)` but wraps the `stream`.
`static RecordParser`	RecordParser.`newFixed(int size, ReadStream<Buffer> stream)`	Like `RecordParser.newFixed(int)` but wraps the `stream`.
`static JsonParser`	JsonParser.`newParser(ReadStream<Buffer> stream)`	Create a new `JsonParser` instance.

Uses of ReadStream in io.vertx.core.streams

Methods in io.vertx.core.streams that return ReadStream
Modifier and Type	Method	Description
`ReadStream<T>`	ReadStream.`endHandler(Handler<Void> endHandler)`	Set an end handler.
`ReadStream<T>`	ReadStream.`exceptionHandler(Handler<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(Handler<T> handler)`	Set a data handler.
`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.ext.cluster.infinispan

Methods in io.vertx.ext.cluster.infinispan that return ReadStream
Modifier and Type	Method	Description
`ReadStream<Map.Entry<K,V>>`	InfinispanAsyncMap.`entryStream()`	Get the entries of the map as a `ReadStream`.
`ReadStream<K>`	InfinispanAsyncMap.`keyStream()`	Get the keys of the map as a `ReadStream`.
`ReadStream<V>`	InfinispanAsyncMap.`valueStream()`	Get the values of the map as a `ReadStream`.

Uses of ReadStream in io.vertx.ext.mail

Methods in io.vertx.ext.mail that return ReadStream
Modifier and Type	Method	Description
`ReadStream<Buffer>`	MailAttachment.`getStream()`	Gets the data stream.

Methods in io.vertx.ext.mail with parameters of type ReadStream
Modifier and Type	Method	Description
`MailAttachment`	MailAttachment.`setStream(ReadStream<Buffer> stream)`	Sets the data stream.

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

Methods in io.vertx.ext.mail.mailencoder that return ReadStream
Modifier and Type	Method	Description
`ReadStream<Buffer>`	EncodedPart.`bodyStream(Context context)`
`ReadStream<Buffer>`	EncodedPart.`dkimBodyStream(Context context)`

Uses of ReadStream in io.vertx.ext.mongo

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

Methods in io.vertx.ext.mongo with parameters of type ReadStream
Modifier and Type	Method	Description
`Future<String>`	MongoGridFsClient.`uploadByFileName(ReadStream<Buffer> stream, String fileName)`
`Future<String>`	MongoGridFsClient.`uploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options)`

Uses of ReadStream in io.vertx.ext.reactivestreams

Subinterfaces of ReadStream in io.vertx.ext.reactivestreams
Modifier and Type	Interface	Description
`interface`	`ReactiveReadStream<T>`	A Vert.x read stream that also implements reactive streams subscriber interface.

Uses of ReadStream in io.vertx.ext.unit.report

Subinterfaces of ReadStream in io.vertx.ext.unit.report
Modifier and Type	Interface	Description
`interface`	`TestSuiteReport`	The test suite reports is basically a stream of events reporting the test suite execution.

Uses of ReadStream in io.vertx.ext.web

Subinterfaces of ReadStream in io.vertx.ext.web
Modifier and Type Interface Description

interface WebServerRequest
Extends to access the routing context associated with the request.

Subinterfaces of ReadStream in io.vertx.ext.web
Modifier and Type	Interface	Description
`interface`	`WebServerRequest`	Extends to access the routing context associated with the request.

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

Methods in io.vertx.ext.web.client with parameters of type ReadStream
Modifier and Type	Method	Description
`Future<HttpResponse<T>>`	HttpRequest.`sendStream(ReadStream<Buffer> body)`	Like `HttpRequest.send()` but with an HTTP request `body` stream.

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

Subinterfaces of ReadStream in io.vertx.ext.web.handler.sockjs
Modifier and Type	Interface	Description
`interface`	`SockJSSocket`	You interact with SockJS clients through instances of SockJS socket.

Uses of ReadStream in io.vertx.grpc.client

Subinterfaces of ReadStream in io.vertx.grpc.client
Modifier and Type	Interface	Description
`interface`	`GrpcClientResponse<Req,Resp>`	A response from a gRPC server.

Methods in io.vertx.grpc.client with parameters of type ReadStream
Modifier and Type	Method	Description
`default Future<GrpcClientResponse<Req,Resp>>`	GrpcClientRequest.`send(ReadStream<Req> body)`

Uses of ReadStream in io.vertx.grpc.common

Subinterfaces of ReadStream in io.vertx.grpc.common
Modifier and Type Interface Description

interface GrpcReadStream<T>
Uses of ReadStream in io.vertx.grpc.server

Subinterfaces of ReadStream in io.vertx.grpc.server
Modifier and Type Interface Description

interface GrpcServerRequest<Req,Resp>

Methods in io.vertx.grpc.server with parameters of type ReadStream
Modifier and Type Method Description

default Future<Void> GrpcServerResponse.send(ReadStream<Resp> body)

Subinterfaces of ReadStream in io.vertx.grpc.common
Modifier and Type	Interface	Description
`interface`	`GrpcReadStream<T>`

Subinterfaces of ReadStream in io.vertx.grpc.server
Modifier and Type	Interface	Description
`interface`	`GrpcServerRequest<Req,Resp>`

Methods in io.vertx.grpc.server with parameters of type ReadStream
Modifier and Type	Method	Description
`default Future<Void>`	GrpcServerResponse.`send(ReadStream<Resp> body)`

Uses of ReadStream in io.vertx.grpc.stub

Methods in io.vertx.grpc.stub that return ReadStream
Modifier and Type	Method	Description
`static <I,O> ReadStream<O>`	ClientCalls.`manyToMany(io.vertx.core.internal.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, java.util.function.Function<StreamObserver<O>,StreamObserver<I>> delegate)`
`static <I,O> ReadStream<O>`	ClientCalls.`manyToMany(io.vertx.core.internal.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, java.util.function.Function<StreamObserver<O>,StreamObserver<I>> delegate, Handler<Throwable> exceptionHandler)`
`static <I,O> ReadStream<O>`	ClientCalls.`manyToMany(io.vertx.core.internal.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, java.util.function.Function<StreamObserver<O>,StreamObserver<I>> delegate, Handler<O> handler, Handler<Void> endHandler, Handler<Throwable> exceptionHandler)`
`static <I,O> ReadStream<O>`	ClientCalls.`oneToMany(io.vertx.core.internal.ContextInternal ctx, I request, java.util.function.BiConsumer<I,StreamObserver<O>> delegate)`
`static <I,O> ReadStream<O>`	ClientCalls.`oneToMany(io.vertx.core.internal.ContextInternal ctx, I request, java.util.function.BiConsumer<I,StreamObserver<O>> delegate, Handler<O> handler, Handler<Void> endHandler, Handler<Throwable> exceptionHandler)`

Method parameters in io.vertx.grpc.stub with type arguments of type ReadStream
Modifier and Type	Method	Description
`static <I,O> StreamObserver<I>`	ServerCalls.`manyToMany(StreamObserver<O> response, String compression, java.util.function.BiConsumer<ReadStream<I>,WriteStream<O>> delegate)`
`static <I,O> StreamObserver<I>`	ServerCalls.`manyToOne(StreamObserver<O> response, String compression, java.util.function.Function<ReadStream<I>,Future<O>> delegate)`

Uses of ReadStream in io.vertx.httpproxy

Methods in io.vertx.httpproxy that return ReadStream
Modifier and Type	Method	Description
`ReadStream<Buffer>`	Body.`stream()`	Get stream of the `Body`.

Methods in io.vertx.httpproxy with parameters of type ReadStream
Modifier and Type	Method	Description
`static Body`	Body.`body(ReadStream<Buffer> stream)`	Create a new `Body` instance.
`static Body`	Body.`body(ReadStream<Buffer> stream, long len)`	Create a new `Body` instance.

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

Subinterfaces of ReadStream in io.vertx.kafka.client.consumer
Modifier and Type	Interface	Description
`interface`	`KafkaConsumer<K,V>`	Vert.x Kafka consumer.
`interface`	`KafkaReadStream<K,V>`	A `ReadStream` for consuming Kafka `ConsumerRecord`.

Uses of ReadStream in io.vertx.pgclient.pubsub

Subinterfaces of ReadStream in io.vertx.pgclient.pubsub
Modifier and Type	Interface	Description
`interface`	`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.rabbitmq

Subinterfaces of ReadStream in io.vertx.rabbitmq
Modifier and Type	Interface	Description
`interface`	`RabbitMQConsumer`	A stream of messages from a rabbitmq queue.

Methods in io.vertx.rabbitmq that return ReadStream
Modifier and Type	Method	Description
`ReadStream<RabbitMQPublisherConfirmation>`	RabbitMQPublisher.`getConfirmationStream()`	Get the ReadStream that contains the message IDs for confirmed messages.

Methods in io.vertx.rabbitmq that return types with arguments of type ReadStream
Modifier and Type	Method	Description
`Future<ReadStream<RabbitMQConfirmation>>`	RabbitMQClient.`addConfirmListener(int maxQueueSize)`	Add a Confirm Listener to the channel.

Uses of ReadStream in io.vertx.reactivex

Methods in io.vertx.reactivex that return ReadStream
Modifier and Type	Method	Description
`static <T> ReadStream<T>`	FlowableHelper.`toReadStream(Flowable<T> observable)`	Adapts an RxJava `Flowable` to a Vert.x `ReadStream`.
`static <T> ReadStream<T>`	ObservableHelper.`toReadStream(Observable<T> observable)`	Adapts an RxJava `Observable` to a Vert.x `ReadStream`.

Methods in io.vertx.reactivex with parameters of type ReadStream
Modifier and Type	Method	Description
`static <T> Flowable<T>`	FlowableHelper.`toFlowable(ReadStream<T> stream)`	Adapts a Vert.x `ReadStream` to an RxJava `Flowable`.
`static <T> Flowable<T>`	FlowableHelper.`toFlowable(ReadStream<T> stream, long maxBufferSize)`	Adapts a Vert.x `ReadStream` to an RxJava `Flowable`.
`static <T,U> Flowable<U>`	FlowableHelper.`toFlowable(ReadStream<T> stream, java.util.function.Function<T,U> mapping)`	Like `FlowableHelper.toFlowable(ReadStream)` but with a `mapping` function
`static <T> Observable<T>`	ObservableHelper.`toObservable(ReadStream<T> stream)`	Adapts a Vert.x to an RxJava .
`static <T,U> Observable<U>`	ObservableHelper.`toObservable(ReadStream<T> stream, java.util.function.Function<T,U> mapping)`	Like `ObservableHelper.toObservable(ReadStream)` but with a `mapping` function

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

Methods in io.vertx.reactivex.core.streams that return ReadStream
Modifier and Type	Method	Description
`ReadStream`	ReadStream.`getDelegate()`

Methods in io.vertx.reactivex.core.streams with parameters of type ReadStream
Modifier and Type	Method	Description
`static <T> ReadStream<T>`	ReadStream.`newInstance(ReadStream arg)`
`static <T> ReadStream<T>`	ReadStream.`newInstance(ReadStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)`

Uses of ReadStream in io.vertx.redis.client

Subinterfaces of ReadStream in io.vertx.redis.client
Modifier and Type Interface Description

interface RedisConnection
A simple Redis client.

Subinterfaces of ReadStream in io.vertx.redis.client
Modifier and Type	Interface	Description
`interface`	`RedisConnection`	A simple Redis client.

Uses of ReadStream in io.vertx.rxjava3

Methods in io.vertx.rxjava3 that return ReadStream
Modifier and Type	Method	Description
`static <T> ReadStream<T>`	FlowableHelper.`toReadStream(Flowable<T> observable)`	Adapts an RxJava `Flowable` to a Vert.x `ReadStream`.
`static <T> ReadStream<T>`	ObservableHelper.`toReadStream(Observable<T> observable)`	Adapts an RxJava `Observable` to a Vert.x `ReadStream`.

Methods in io.vertx.rxjava3 with parameters of type ReadStream
Modifier and Type	Method	Description
`static <T> Flowable<T>`	FlowableHelper.`toFlowable(ReadStream<T> stream)`	Adapts a Vert.x `ReadStream` to an RxJava `Flowable`.
`static <T> Flowable<T>`	FlowableHelper.`toFlowable(ReadStream<T> stream, long maxBufferSize)`	Adapts a Vert.x `ReadStream` to an RxJava `Flowable`.
`static <T,U> Flowable<U>`	FlowableHelper.`toFlowable(ReadStream<T> stream, java.util.function.Function<T,U> mapping)`	Like `FlowableHelper.toFlowable(ReadStream)` but with a `mapping` function
`static <T> Observable<T>`	ObservableHelper.`toObservable(ReadStream<T> stream)`	Adapts a Vert.x to an RxJava .
`static <T,U> Observable<U>`	ObservableHelper.`toObservable(ReadStream<T> stream, java.util.function.Function<T,U> mapping)`	Like `ObservableHelper.toObservable(ReadStream)` but with a `mapping` function

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

Methods in io.vertx.rxjava3.core.streams that return ReadStream
Modifier and Type	Method	Description
`ReadStream`	ReadStream.`getDelegate()`

Methods in io.vertx.rxjava3.core.streams with parameters of type ReadStream
Modifier and Type	Method	Description
`static <T> ReadStream<T>`	ReadStream.`newInstance(ReadStream arg)`
`static <T> ReadStream<T>`	ReadStream.`newInstance(ReadStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)`

Uses of ReadStream in io.vertx.sqlclient

Subinterfaces of ReadStream in io.vertx.sqlclient
Modifier and Type Interface Description

interface RowStream<T>
A row oriented stream.

Uses of Interfaceio.vertx.core.streams.ReadStream

Uses of ReadStream in io.vertx.amqp

Uses of ReadStream in io.vertx.cassandra

Uses of ReadStream in io.vertx.config

Uses of ReadStream in io.vertx.core.eventbus

Uses of ReadStream in io.vertx.core.file

Uses of ReadStream in io.vertx.core.http

Uses of ReadStream in io.vertx.core.net

Uses of ReadStream in io.vertx.core.parsetools

Uses of ReadStream in io.vertx.core.streams

Uses of ReadStream in io.vertx.ext.cluster.infinispan

Uses of ReadStream in io.vertx.ext.mail

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

Uses of ReadStream in io.vertx.ext.mongo

Uses of ReadStream in io.vertx.ext.reactivestreams

Uses of ReadStream in io.vertx.ext.unit.report

Uses of ReadStream in io.vertx.ext.web

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

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

Uses of ReadStream in io.vertx.grpc.client

Uses of ReadStream in io.vertx.grpc.common

Uses of ReadStream in io.vertx.grpc.server

Uses of ReadStream in io.vertx.grpc.stub

Uses of ReadStream in io.vertx.httpproxy

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

Uses of ReadStream in io.vertx.pgclient.pubsub

Uses of ReadStream in io.vertx.rabbitmq

Uses of ReadStream in io.vertx.reactivex

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

Uses of ReadStream in io.vertx.redis.client

Uses of ReadStream in io.vertx.rxjava3

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

Uses of ReadStream in io.vertx.sqlclient

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