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

- 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()` |

  - ### 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.

  - ### 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)` |

  - ### 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.

  - ### 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.