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

- Packages that use ReadStream
  Package | Description
  --- | ---
  io.vertx.reactivex.config |
  io.vertx.reactivex.core.eventbus |
  io.vertx.reactivex.core.http |
  io.vertx.reactivex.core.net |
  io.vertx.reactivex.core.parsetools |
  io.vertx.reactivex.core.streams |
  io.vertx.reactivex.ext.mail |
  io.vertx.reactivex.ext.mongo |
  io.vertx.reactivex.ext.sql |
  io.vertx.reactivex.ext.unit.report |
  io.vertx.reactivex.ext.web.client |
  io.vertx.reactivex.grpc.client |
  io.vertx.reactivex.grpc.server |
  io.vertx.reactivex.pgclient.pubsub |
  io.vertx.reactivex.rabbitmq |

- - ### Uses of ReadStream in io.vertx.reactivex.config

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

  - ### Uses of ReadStream in io.vertx.reactivex.core.eventbus

    Methods in io.vertx.reactivex.core.eventbus that return ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `ReadStream<T>` | MessageConsumer.`bodyStream()`

  - ### Uses of ReadStream in io.vertx.reactivex.core.http

    Subinterfaces of ReadStream in io.vertx.reactivex.core.http
    Modifier and Type | Interface and Description
    --- | ---
    `interface` | `WebSocketBase` Base WebSocket implementation.

    Methods in io.vertx.reactivex.core.http that return ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `ReadStream<HttpServerRequest>` | HttpServer.`requestStream()` Deprecated.
    `ReadStream<ServerWebSocket>` | HttpServer.`webSocketStream()` Deprecated.

    Methods in io.vertx.reactivex.core.http with parameters of type ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `Single<HttpClientResponse>` | HttpClientRequest.`rxSend(ReadStream<Buffer> body)` Send the request with a stream `body`.
    `Completable` | HttpServerResponse.`rxSend(ReadStream<Buffer> body)` Send the request with a stream `body`.
    `void` | HttpClientRequest.`send(ReadStream<Buffer> body)` Send the request with a stream `body`.
    `void` | HttpServerResponse.`send(ReadStream<Buffer> body)` Send the request with a stream `body`.
    `void` | HttpClientRequest.`send(ReadStream<Buffer> body, Handler<AsyncResult<HttpClientResponse>> handler)` Send the request with a stream `body`.
    `void` | HttpServerResponse.`send(ReadStream<Buffer> body, Handler<AsyncResult<Void>> handler)` Send the request with a stream `body`.

  - ### Uses of ReadStream in io.vertx.reactivex.core.net

    Methods in io.vertx.reactivex.core.net that return ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `ReadStream<NetSocket>` | NetServer.`connectStream()` Deprecated.

  - ### Uses of ReadStream in io.vertx.reactivex.core.parsetools

    Methods in io.vertx.reactivex.core.parsetools with parameters of type ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `static RecordParser` | RecordParser.`newDelimited(Buffer delim, ReadStream<Buffer> stream)` Like `RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.reactivex.core.buffer.Buffer>)` but wraps the `stream`.
    `static RecordParser` | RecordParser.`newDelimited(String delim, ReadStream<Buffer> stream)` Like `RecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.reactivex.core.buffer.Buffer>)` 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.reactivex.core.streams

    Methods in io.vertx.reactivex.core.streams that return ReadStream
    Modifier and Type | Method and 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.
    `static <T> ReadStream<T>` | ReadStream.`newInstance(ReadStream arg)`
    `static <T> ReadStream<T>` | ReadStream.`newInstance(ReadStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)`
    `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.

    Methods in io.vertx.reactivex.core.streams with parameters of type ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `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.

  - ### Uses of ReadStream in io.vertx.reactivex.ext.mail

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

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

  - ### Uses of ReadStream in io.vertx.reactivex.ext.mongo

    Methods in io.vertx.reactivex.ext.mongo that return ReadStream
    Modifier and Type | Method and 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, 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, 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.`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.reactivex.ext.mongo with parameters of type ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `Single<String>` | MongoGridFsClient.`rxUploadByFileName(ReadStream<Buffer> stream, String fileName)`
    `Single<String>` | MongoGridFsClient.`rxUploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options)`
    `MongoGridFsClient` | MongoGridFsClient.`uploadByFileName(ReadStream<Buffer> stream, String fileName)`
    `MongoGridFsClient` | MongoGridFsClient.`uploadByFileName(ReadStream<Buffer> stream, String fileName, Handler<AsyncResult<String>> resultHandler)`
    `MongoGridFsClient` | MongoGridFsClient.`uploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options)`
    `MongoGridFsClient` | MongoGridFsClient.`uploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options, Handler<AsyncResult<String>> resultHandler)`

  - ### Uses of ReadStream in io.vertx.reactivex.ext.sql

    Methods in io.vertx.reactivex.ext.sql that return ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `ReadStream<JsonArray>` | SQLRowStream.`fetch(long amount)` Fetch the specified `amount` of elements.

  - ### Uses of ReadStream in io.vertx.reactivex.ext.unit.report

    Methods in io.vertx.reactivex.ext.unit.report that return ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `ReadStream<TestCaseReport>` | TestSuiteReport.`fetch(long amount)` Fetch the specified `amount` of elements.

  - ### Uses of ReadStream in io.vertx.reactivex.ext.web.client

    Methods in io.vertx.reactivex.ext.web.client with parameters of type ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `Single<HttpResponse<T>>` | HttpRequest.`rxSendStream(ReadStream<Buffer> body)` Like `HttpRequest.send(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>>)` but with an HTTP request `body` stream.
    `void` | HttpRequest.`sendStream(ReadStream<Buffer> body)` Like `HttpRequest.send(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>>)` but with an HTTP request `body` stream.
    `void` | HttpRequest.`sendStream(ReadStream<Buffer> body, Handler<AsyncResult<HttpResponse<T>>> handler)` Like `HttpRequest.send(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>>)` but with an HTTP request `body` stream.

  - ### Uses of ReadStream in io.vertx.reactivex.grpc.client

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

  - ### Uses of ReadStream in io.vertx.reactivex.grpc.server

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

  - ### Uses of ReadStream in io.vertx.reactivex.pgclient.pubsub

    Methods in io.vertx.reactivex.pgclient.pubsub that return ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `ReadStream<String>` | PgChannel.`fetch(long amount)` Fetch the specified `amount` of elements.

  - ### Uses of ReadStream in io.vertx.reactivex.rabbitmq

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

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

    Method parameters in io.vertx.reactivex.rabbitmq with type arguments of type ReadStream
    Modifier and Type | Method and Description
    --- | ---
    `void` | RabbitMQClient.`addConfirmListener(int maxQueueSize, Handler<AsyncResult<ReadStream<RabbitMQConfirmation>>> resultHandler)` Add a Confirm Listener to the channel.

Copyright © 2025 Eclipse. All rights reserved.