Uses of Class
io.vertx.rxjava3.core.streams.Pipe

Packages that use Pipe

Package	Description
io.vertx.rxjava3.amqp
io.vertx.rxjava3.cassandra
io.vertx.rxjava3.core.eventbus
io.vertx.rxjava3.core.file
io.vertx.rxjava3.core.http
io.vertx.rxjava3.core.net
io.vertx.rxjava3.core.parsetools
io.vertx.rxjava3.core.streams
io.vertx.rxjava3.ext.unit.report
io.vertx.rxjava3.ext.web.handler.sockjs
io.vertx.rxjava3.grpc.client
io.vertx.rxjava3.grpc.common
io.vertx.rxjava3.grpc.server
io.vertx.rxjava3.kafka.client.consumer
io.vertx.rxjava3.pgclient.pubsub
io.vertx.rxjava3.rabbitmq
io.vertx.rxjava3.redis.client
io.vertx.rxjava3.sqlclient

Uses of Pipe in io.vertx.rxjava3.amqp

Methods in io.vertx.rxjava3.amqp that return Pipe

Modifier and Type	Method	Description
Pipe<AmqpMessage>	AmqpReceiver.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.cassandra

Methods in io.vertx.rxjava3.cassandra that return Pipe

Modifier and Type	Method	Description
Pipe<com.datastax.oss.driver.api.core.cql.Row>	CassandraRowStream.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.core.eventbus

Methods in io.vertx.rxjava3.core.eventbus that return Pipe

Modifier and Type	Method	Description
Pipe<Message<T>>	MessageConsumer.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.core.file

Methods in io.vertx.rxjava3.core.file that return Pipe

Modifier and Type	Method	Description
Pipe<Buffer>	AsyncFile.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.core.http

Methods in io.vertx.rxjava3.core.http that return Pipe

Modifier and Type	Method	Description
Pipe<Buffer>	ClientWebSocket.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	HttpClientResponse.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	HttpServerFileUpload.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	HttpServerRequest.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	ServerWebSocket.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	WebSocket.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	WebSocketBase.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.core.net

Methods in io.vertx.rxjava3.core.net that return Pipe

Modifier and Type	Method	Description
Pipe<Buffer>	NetSocket.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	QuicStream.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	StreamChannel.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.core.parsetools

Methods in io.vertx.rxjava3.core.parsetools that return Pipe

Modifier and Type	Method	Description
Pipe<JsonEvent>	JsonParser.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
Pipe<Buffer>	RecordParser.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

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

Fields in io.vertx.rxjava3.core.streams with type parameters of type Pipe

Modifier and Type	Field	Description
static final io.vertx.lang.rx.TypeArg<Pipe>	Pipe.__TYPE_ARG

Methods in io.vertx.rxjava3.core.streams that return Pipe

Modifier and Type	Method	Description
Pipe<T>	Pipe.endOnComplete(boolean end)	Set to true to call WriteStream.end() when the source ReadStream completes, false otherwise.
Pipe<T>	Pipe.endOnFailure(boolean end)	Set to true to call WriteStream.end() when the source ReadStream fails, false otherwise.
Pipe<T>	Pipe.endOnSuccess(boolean end)	Set to true to call WriteStream.end() when the source ReadStream succeeds, false otherwise.
static <T> Pipe<T>	Pipe.newInstance(Pipe arg)
static <T> Pipe<T>	Pipe.newInstance(Pipe arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)
Pipe<T>	ReadStream.pipe()	Pause this stream and return a Pipe to transfer the elements of this stream to a destination WriteStream.

Uses of Pipe in io.vertx.rxjava3.ext.unit.report

Methods in io.vertx.rxjava3.ext.unit.report that return Pipe

Modifier and Type	Method	Description
Pipe<TestCaseReport>	TestSuiteReport.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.ext.web.handler.sockjs

Methods in io.vertx.rxjava3.ext.web.handler.sockjs that return Pipe

Modifier and Type	Method	Description
Pipe<Buffer>	SockJSSocket.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.grpc.client

Methods in io.vertx.rxjava3.grpc.client that return Pipe

Modifier and Type	Method	Description
Pipe<Resp>	GrpcClientResponse.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.grpc.common

Methods in io.vertx.rxjava3.grpc.common that return Pipe

Modifier and Type	Method	Description
Pipe<T>	GrpcReadStream.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.grpc.server

Methods in io.vertx.rxjava3.grpc.server that return Pipe

Modifier and Type	Method	Description
Pipe<Req>	GrpcServerRequest.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.kafka.client.consumer

Methods in io.vertx.rxjava3.kafka.client.consumer that return Pipe

Modifier and Type	Method	Description
Pipe<KafkaConsumerRecord<K,V>>	KafkaConsumer.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.pgclient.pubsub

Methods in io.vertx.rxjava3.pgclient.pubsub that return Pipe

Modifier and Type	Method	Description
Pipe<String>	PgChannel.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.rabbitmq

Methods in io.vertx.rxjava3.rabbitmq that return Pipe

Modifier and Type	Method	Description
Pipe<RabbitMQMessage>	RabbitMQConsumer.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.redis.client

Methods in io.vertx.rxjava3.redis.client that return Pipe

Modifier and Type	Method	Description
Pipe<Response>	RedisConnection.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .

Uses of Pipe in io.vertx.rxjava3.sqlclient

Methods in io.vertx.rxjava3.sqlclient that return Pipe

Modifier and Type	Method	Description
Pipe<T>	RowStream.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .