## 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 |
  io.vertx.rxjava3.core.datagram |
  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 and 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 and 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

    Methods in io.vertx.rxjava3.core that return Pipe
    Modifier and Type | Method and Description
    --- | ---
    `Pipe<Long>` | TimeoutStream.`pipe()` Deprecated.

  - ### Uses of Pipe in io.vertx.rxjava3.core.datagram

    Methods in io.vertx.rxjava3.core.datagram that return Pipe
    Modifier and Type | Method and Description
    --- | ---
    `Pipe<DatagramPacket>` | DatagramSocket.`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 and 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 and 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 and Description
    --- | ---
    `Pipe<Buffer>` | WebSocket.`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>` | ClientWebSocket.`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>` | 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>` | 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 and Description
    --- | ---
    `Pipe<Buffer>` | NetSocket.`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 and 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 and Description
    --- | ---
    `static io.vertx.lang.rx.TypeArg<Pipe>` | Pipe.`__TYPE_ARG`

    Methods in io.vertx.rxjava3.core.streams that return Pipe
    Modifier and Type | Method and 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 and 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 and 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 and 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 and 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 and 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 and 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 and 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 and 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 and 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 and Description
    --- | ---
    `Pipe<T>` | RowStream.`pipe()` Pause this stream and return a to transfer the elements of this stream to a destination .

Copyright © 2025 Eclipse. All rights reserved.