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

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