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
io.vertx.core.datagram
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.sql
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.rx.java
io.vertx.rxjava.core.streams
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 and 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 and 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 and Description
ReadStream<JsonObject>	ConfigRetriever.configStream()

Uses of ReadStream in io.vertx.core

Subinterfaces of ReadStream in io.vertx.core

Modifier and Type	Interface and Description
interface	TimeoutStream Deprecated. use Vertx.setTimer(long, io.vertx.core.Handler<java.lang.Long>)/Vertx.setPeriodic(long, io.vertx.core.Handler<java.lang.Long>) instead. RxJava like integrations should use the Vert.x scheduler integration.

Uses of ReadStream in io.vertx.core.datagram

Subinterfaces of ReadStream in io.vertx.core.datagram

Modifier and Type	Interface and Description
interface	DatagramSocket A datagram socket can be used to send DatagramPacket's to remote datagram servers and receive DatagramPackets .

Uses of ReadStream in io.vertx.core.eventbus

Subinterfaces of ReadStream in io.vertx.core.eventbus

Modifier and Type	Interface and 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 and 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 and 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 and Description
interface	ClientWebSocket Represents a client-side WebSocket initially not connected.
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 Represents a client-side WebSocket.
interface	WebSocketBase Base WebSocket implementation.

Methods in io.vertx.core.http that return ReadStream

Modifier and Type	Method and Description
ReadStream<HttpServerRequest>	HttpServer.requestStream() Deprecated. instead use HttpServer.requestHandler(Handler)
ReadStream<ServerWebSocket>	HttpServer.webSocketStream() Deprecated. instead use HttpServer.webSocketHandler(Handler)

Methods in io.vertx.core.http with parameters of type ReadStream

Modifier and Type	Method and Description
default Future<Void>	HttpServerResponse.send(ReadStream<Buffer> body) Like HttpServerResponse.send(ReadStream, Handler) but returns a Future of the asynchronous result
default Future<HttpClientResponse>	HttpClientRequest.send(ReadStream<Buffer> body) Like HttpClientRequest.send(ReadStream, Handler) but returns a Future of the asynchronous result
default void	HttpClientRequest.send(ReadStream<Buffer> body, Handler<AsyncResult<HttpClientResponse>> handler) Send the request with a stream body.
default void	HttpServerResponse.send(ReadStream<Buffer> body, Handler<AsyncResult<Void>> handler) 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 and Description
interface	NetSocket Represents a socket-like interface to a TCP connection on either the client or the server side.

Methods in io.vertx.core.net that return ReadStream

Modifier and Type	Method and Description
ReadStream<NetSocket>	NetServer.connectStream() Deprecated. instead use NetServer.connectHandler(Handler)

Uses of ReadStream in io.vertx.core.parsetools

Subinterfaces of ReadStream in io.vertx.core.parsetools

Modifier and Type	Interface and 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 and 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 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.
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.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. Create a new Pump with the given ReadStream and WriteStream
static <T> Pump	Pump.pump(ReadStream<T> rs, WriteStream<T> ws, int writeQueueMaxSize) Deprecated. Create a new Pump with the given ReadStream and WriteStream and writeQueueMaxSize

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

Methods in io.vertx.ext.cluster.infinispan that return ReadStream

Modifier and Type	Method and 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 and Description
ReadStream<Buffer>	MailAttachment.getStream() Gets the data stream.

Methods in io.vertx.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.ext.mail.mailencoder

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

Modifier and Type	Method and 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 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.ext.mongo with parameters of type ReadStream

Modifier and Type	Method and Description
Future<String>	MongoGridFsClient.uploadByFileName(ReadStream<Buffer> stream, String fileName) Like MongoGridFsClient.uploadByFileName(ReadStream, String, Handler) but returns a Future of the asynchronous result
MongoGridFsClient	MongoGridFsClient.uploadByFileName(ReadStream<Buffer> stream, String fileName, Handler<AsyncResult<String>> resultHandler)
Future<String>	MongoGridFsClient.uploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options) Like MongoGridFsClient.uploadByFileNameWithOptions(ReadStream, String, GridFsUploadOptions, Handler) but returns a Future of the asynchronous result
MongoGridFsClient	MongoGridFsClient.uploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options, Handler<AsyncResult<String>> resultHandler)

Uses of ReadStream in io.vertx.ext.reactivestreams

Subinterfaces of ReadStream in io.vertx.ext.reactivestreams

Modifier and Type	Interface and Description
interface	ReactiveReadStream<T> A Vert.x read stream that also implements reactive streams subscriber interface.

Uses of ReadStream in io.vertx.ext.sql

Subinterfaces of ReadStream in io.vertx.ext.sql

Modifier and Type	Interface and Description
interface	SQLRowStream A ReadStream of Rows from the underlying RDBMS.

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

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

Modifier and Type	Interface and 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 and 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 and Description
default Future<HttpResponse<T>>	HttpRequest.sendStream(ReadStream<Buffer> body)
void	HttpRequest.sendStream(ReadStream<Buffer> body, Handler<AsyncResult<HttpResponse<T>>> handler) Like HttpRequest.send(Handler) 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 and 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 and 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 and 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 and Description
interface	GrpcReadStream<T>

Uses of ReadStream in io.vertx.grpc.server

Subinterfaces of ReadStream in io.vertx.grpc.server

Modifier and Type	Interface and Description
interface	GrpcServerRequest<Req,Resp>

Methods in io.vertx.grpc.server with parameters of type ReadStream

Modifier and Type	Method and 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 and Description
static <I,O> ReadStream<O>	ClientCalls.manyToMany(io.vertx.core.impl.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate)
static <I,O> ReadStream<O>	ClientCalls.manyToMany(io.vertx.core.impl.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate, Handler<O> handler, Handler<Void> endHandler, Handler<Throwable> exceptionHandler)
static <I,O> ReadStream<O>	ClientCalls.manyToMany(io.vertx.core.impl.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate, Handler<Throwable> exceptionHandler)
static <I,O> ReadStream<O>	ClientCalls.oneToMany(io.vertx.core.impl.ContextInternal ctx, I request, java.util.function.BiConsumer<I,io.grpc.stub.StreamObserver<O>> delegate)
static <I,O> ReadStream<O>	ClientCalls.oneToMany(io.vertx.core.impl.ContextInternal ctx, I request, java.util.function.BiConsumer<I,io.grpc.stub.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 and Description
static <I,O> io.grpc.stub.StreamObserver<I>	ServerCalls.manyToMany(io.grpc.stub.StreamObserver<O> response, String compression, java.util.function.BiConsumer<ReadStream<I>,WriteStream<O>> delegate)
static <I,O> io.grpc.stub.StreamObserver<I>	ServerCalls.manyToOne(io.grpc.stub.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 and Description
ReadStream<Buffer>	Body.stream() Get stream of the Body.

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

Modifier and Type	Method and 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 and 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 and 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 and Description
interface	RabbitMQConsumer A stream of messages from a rabbitmq queue.

Methods in io.vertx.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.rabbitmq that return types with arguments of type ReadStream

Modifier and Type	Method and Description
Future<ReadStream<RabbitMQConfirmation>>	RabbitMQClient.addConfirmListener(int maxQueueSize) Add a Confirm Listener to the channel.

Method parameters in io.vertx.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.

Uses of ReadStream in io.vertx.reactivex

Methods in io.vertx.reactivex that return ReadStream

Modifier and Type	Method and Description
static <T> ReadStream<T>	FlowableHelper.toReadStream(Flowable<T> observable) Adapts an RxJava Flowable to a Vert.x io.vertx.core.streams.ReadStream.
static <T> ReadStream<T>	ObservableHelper.toReadStream(Observable<T> observable) Adapts an RxJava Observable to a Vert.x io.vertx.core.streams.ReadStream.

Methods in io.vertx.reactivex with parameters of type ReadStream

Modifier and Type	Method and Description
static <T> Flowable<T>	FlowableHelper.toFlowable(ReadStream<T> stream) 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> Flowable<T>	FlowableHelper.toFlowable(ReadStream<T> stream, long maxBufferSize) Adapts a Vert.x ReadStream to an RxJava Flowable.
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 and Description
ReadStream	ReadStream.getDelegate()

Methods in io.vertx.reactivex.core.streams with parameters of type ReadStream

Modifier and Type	Method and 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 and Description
interface	RedisConnection A simple Redis client.

Uses of ReadStream in io.vertx.rx.java

Classes in io.vertx.rx.java that implement ReadStream

Modifier and Type	Class and Description
class	ReadStreamSubscriber<R,J> An RxJava Subscriber that turns an Observable into a ReadStream.

Methods in io.vertx.rx.java that return ReadStream

Modifier and Type	Method and Description
static <R,J> ReadStream<J>	ReadStreamSubscriber.asReadStream(Observable<R> observable, java.util.function.Function<R,J> adapter)
ReadStream<J>	ReadStreamSubscriber.endHandler(Handler<Void> handler)
ReadStream<J>	ReadStreamSubscriber.exceptionHandler(Handler<Throwable> handler)
ReadStream<J>	ReadStreamSubscriber.fetch(long amount)
ReadStream<J>	ReadStreamSubscriber.handler(Handler<J> handler)
ReadStream<J>	ReadStreamSubscriber.pause()
ReadStream<J>	ReadStreamSubscriber.resume()
static <T> ReadStream<T>	RxHelper.toReadStream(Observable<T> observable) Adapts an RxJava Observable to a Vert.x io.vertx.core.streams.ReadStream.

Methods in io.vertx.rx.java with parameters of type ReadStream

Modifier and Type	Method and Description
static <T> Observable<T>	RxHelper.toObservable(ReadStream<T> stream) Adapts a Vert.x io.vertx.core.streams.ReadStream to an RxJava Observable.
static <T,R> Observable<R>	RxHelper.toObservable(ReadStream<T> stream, java.util.function.Function<T,R> adapter) Like RxHelper.toObservable(ReadStream) but with a function that adapts the items.
static <T,R> Observable<R>	RxHelper.toObservable(ReadStream<T> stream, java.util.function.Function<T,R> adapter, int maxBufferSize) Like RxHelper.toObservable(ReadStream, int) but with a function that adapts the items.
static <T> Observable<T>	RxHelper.toObservable(ReadStream<T> stream, int maxBufferSize) Adapts a Vert.x io.vertx.core.streams.ReadStream to an RxJava Observable.

Constructors in io.vertx.rx.java with parameters of type ReadStream

Constructor and Description
ObservableReadStream(ReadStream<T> stream, java.util.function.Function<T,R> adapter)
ObservableReadStream(ReadStream<T> stream, java.util.function.Function<T,R> adapter, long maxBufferSize)

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

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

Modifier and Type	Method and Description
ReadStream	ReadStream.getDelegate()

Methods in io.vertx.rxjava.core.streams with parameters of type ReadStream

Modifier and Type	Method and 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.rxjava3

Methods in io.vertx.rxjava3 that return ReadStream

Modifier and Type	Method and Description
static <T> ReadStream<T>	FlowableHelper.toReadStream(Flowable<T> observable) Adapts an RxJava Flowable to a Vert.x io.vertx.core.streams.ReadStream.
static <T> ReadStream<T>	ObservableHelper.toReadStream(Observable<T> observable) Adapts an RxJava Observable to a Vert.x io.vertx.core.streams.ReadStream.

Methods in io.vertx.rxjava3 with parameters of type ReadStream

Modifier and Type	Method and Description
static <T> Flowable<T>	FlowableHelper.toFlowable(ReadStream<T> stream) 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> Flowable<T>	FlowableHelper.toFlowable(ReadStream<T> stream, long maxBufferSize) Adapts a Vert.x ReadStream to an RxJava Flowable.
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 and Description
ReadStream	ReadStream.getDelegate()

Methods in io.vertx.rxjava3.core.streams with parameters of type ReadStream

Modifier and Type	Method and 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 and Description
interface	RowStream<T> A row oriented stream.