## Uses of Interface
io.vertx.reactivex.core.streams.WriteStream

- Packages that use WriteStream
  Package | Description
  --- | ---
  io.vertx.reactivex.amqp |
  io.vertx.reactivex.cassandra |
  io.vertx.reactivex.core.datagram |
  io.vertx.reactivex.core.eventbus |
  io.vertx.reactivex.core.file |
  io.vertx.reactivex.core.http |
  io.vertx.reactivex.core.net |
  io.vertx.reactivex.core.parsetools |
  io.vertx.reactivex.core.streams |
  io.vertx.reactivex.ext.mongo |
  io.vertx.reactivex.ext.unit.report |
  io.vertx.reactivex.ext.web.codec |
  io.vertx.reactivex.ext.web.handler.sockjs |
  io.vertx.reactivex.grpc.client |
  io.vertx.reactivex.grpc.common |
  io.vertx.reactivex.grpc.server |
  io.vertx.reactivex.kafka.client.consumer |
  io.vertx.reactivex.kafka.client.producer |
  io.vertx.reactivex.pgclient.pubsub |
  io.vertx.reactivex.rabbitmq |
  io.vertx.reactivex.redis.client |
  io.vertx.reactivex.sqlclient |

- - ### Uses of WriteStream in io.vertx.reactivex.amqp

    Classes in io.vertx.reactivex.amqp that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `AmqpSender` | AMQP Sender interface used to send messages.

    Methods in io.vertx.reactivex.amqp that return WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStream<AmqpMessage>` | AmqpSender.`drainHandler​(Handler<Void> handler)` | Set a drain handler on the stream.

    Methods in io.vertx.reactivex.amqp with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | AmqpReceiver.`pipeTo​(WriteStream<AmqpMessage> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | AmqpReceiver.`rxPipeTo​(WriteStream<AmqpMessage> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.cassandra

    Methods in io.vertx.reactivex.cassandra with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | CassandraRowStream.`pipeTo​(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)` |
    `Completable` | CassandraRowStream.`rxPipeTo​(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)` |

  - ### Uses of WriteStream in io.vertx.reactivex.core.datagram

    Methods in io.vertx.reactivex.core.datagram that return WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStream<Buffer>` | DatagramSocket.`sender​(int port, String host)` | Returns a `WriteStream` able to send to the `SocketAddress`.

  - ### Uses of WriteStream in io.vertx.reactivex.core.eventbus

    Methods in io.vertx.reactivex.core.eventbus with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | MessageConsumer.`pipeTo​(WriteStream<Message<T>> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | MessageConsumer.`rxPipeTo​(WriteStream<Message<T>> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.core.file

    Classes in io.vertx.reactivex.core.file that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `AsyncFile` | Represents a file on the file-system which can be read from, or written to asynchronously.

    Methods in io.vertx.reactivex.core.file with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | AsyncFile.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | AsyncFile.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.core.http

    Subinterfaces of WriteStream in io.vertx.reactivex.core.http
    Modifier and Type | Interface | Description
    --- | --- | ---
    `interface` | `WebSocketBase` | Base WebSocket implementation.

    Classes in io.vertx.reactivex.core.http that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `ClientWebSocket` | Represents a client-side WebSocket.
    `class` | `HttpClientRequest` | Represents a client-side HTTP request.
    `class` | `HttpServerResponse` | Represents a server-side HTTP response.
    `class` | `ServerWebSocket` | Represents a server side WebSocket.
    `class` | `WebSocket` | Common WebSocket implementation.

    Methods in io.vertx.reactivex.core.http with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | ClientWebSocket.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Future<Void>` | HttpClientResponse.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Future<Void>` | HttpServerFileUpload.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Future<Void>` | HttpServerRequest.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Future<Void>` | ServerWebSocket.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Future<Void>` | WebSocket.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Future<Void>` | WebSocketBase.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | ClientWebSocket.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | HttpClientResponse.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | HttpServerFileUpload.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | HttpServerRequest.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | ServerWebSocket.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | WebSocket.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | WebSocketBase.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.core.net

    Classes in io.vertx.reactivex.core.net that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `NetSocket` | Represents a socket-like interface to a TCP connection on either the client or the server side.

    Methods in io.vertx.reactivex.core.net with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | NetSocket.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | NetSocket.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.core.parsetools

    Methods in io.vertx.reactivex.core.parsetools with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | JsonParser.`pipeTo​(WriteStream<JsonEvent> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Future<Void>` | RecordParser.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | JsonParser.`rxPipeTo​(WriteStream<JsonEvent> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | RecordParser.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.core.streams

    Methods in io.vertx.reactivex.core.streams that return WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStream<T>` | WriteStream.`drainHandler​(Handler<Void> handler)` | Set a drain handler on the stream.
    `WriteStream<T>` | WriteStream.`exceptionHandler​(Handler<Throwable> handler)` | Set an exception handler on the write stream.
    `static <T> WriteStream<T>` | WriteStream.`newInstance​(WriteStream arg)` |
    `static <T> WriteStream<T>` | WriteStream.`newInstance​(WriteStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)` |
    `WriteStream<T>` | WriteStream.`setWriteQueueMaxSize​(int maxSize)` | Set the maximum size of the write queue to `maxSize`.

    Methods in io.vertx.reactivex.core.streams with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | ReadStream.`pipeTo​(WriteStream<T> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | ReadStream.`rxPipeTo​(WriteStream<T> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | Pipe.`rxTo​(WriteStream<T> dst)` | Start to pipe the elements to the destination `WriteStream`.
    `Future<Void>` | Pipe.`to​(WriteStream<T> dst)` | Start to pipe the elements to the destination `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.ext.mongo

    Methods in io.vertx.reactivex.ext.mongo with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Long>` | MongoGridFsClient.`downloadByFileName​(WriteStream<Buffer> stream, String fileName)` |
    `Future<Long>` | MongoGridFsClient.`downloadByFileNameWithOptions​(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options)` |
    `Future<Long>` | MongoGridFsClient.`downloadById​(WriteStream<Buffer> stream, String id)` |
    `Single<Long>` | MongoGridFsClient.`rxDownloadByFileName​(WriteStream<Buffer> stream, String fileName)` |
    `Single<Long>` | MongoGridFsClient.`rxDownloadByFileNameWithOptions​(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options)` |
    `Single<Long>` | MongoGridFsClient.`rxDownloadById​(WriteStream<Buffer> stream, String id)` |

  - ### Uses of WriteStream in io.vertx.reactivex.ext.unit.report

    Methods in io.vertx.reactivex.ext.unit.report with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | TestSuiteReport.`pipeTo​(WriteStream<TestCaseReport> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | TestSuiteReport.`rxPipeTo​(WriteStream<TestCaseReport> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.ext.web.codec

    Methods in io.vertx.reactivex.ext.web.codec with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `static BodyCodec<Void>` | BodyCodec.`pipe​(WriteStream<Buffer> stream)` | A body codec that pipes the body to a write stream.
    `static BodyCodec<Void>` | BodyCodec.`pipe​(WriteStream<Buffer> stream, boolean close)` | A body codec that pipes the body to a write stream.

  - ### Uses of WriteStream in io.vertx.reactivex.ext.web.handler.sockjs

    Classes in io.vertx.reactivex.ext.web.handler.sockjs that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `SockJSSocket` | You interact with SockJS clients through instances of SockJS socket.

    Methods in io.vertx.reactivex.ext.web.handler.sockjs with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | SockJSSocket.`pipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | SockJSSocket.`rxPipeTo​(WriteStream<Buffer> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.grpc.client

    Classes in io.vertx.reactivex.grpc.client that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `GrpcClientRequest<Req,​Resp>` | A request to a gRPC server.

    Methods in io.vertx.reactivex.grpc.client with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | GrpcClientResponse.`pipeTo​(WriteStream<Resp> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | GrpcClientResponse.`rxPipeTo​(WriteStream<Resp> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.grpc.common

    Classes in io.vertx.reactivex.grpc.common that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `GrpcWriteStream<T>` |

    Methods in io.vertx.reactivex.grpc.common with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | GrpcReadStream.`pipeTo​(WriteStream<T> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | GrpcReadStream.`rxPipeTo​(WriteStream<T> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.grpc.server

    Classes in io.vertx.reactivex.grpc.server that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `GrpcServerResponse<Req,​Resp>` |

    Methods in io.vertx.reactivex.grpc.server with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | GrpcServerRequest.`pipeTo​(WriteStream<Req> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | GrpcServerRequest.`rxPipeTo​(WriteStream<Req> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.kafka.client.consumer

    Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | KafkaConsumer.`pipeTo​(WriteStream<KafkaConsumerRecord<K,​V>> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | KafkaConsumer.`rxPipeTo​(WriteStream<KafkaConsumerRecord<K,​V>> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.kafka.client.producer

    Classes in io.vertx.reactivex.kafka.client.producer that implement WriteStream
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `KafkaProducer<K,​V>` | Vert.x Kafka producer.

  - ### Uses of WriteStream in io.vertx.reactivex.pgclient.pubsub

    Methods in io.vertx.reactivex.pgclient.pubsub with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | PgChannel.`pipeTo​(WriteStream<String> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | PgChannel.`rxPipeTo​(WriteStream<String> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.rabbitmq

    Methods in io.vertx.reactivex.rabbitmq with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | RabbitMQConsumer.`pipeTo​(WriteStream<RabbitMQMessage> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | RabbitMQConsumer.`rxPipeTo​(WriteStream<RabbitMQMessage> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.redis.client

    Methods in io.vertx.reactivex.redis.client with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | RedisConnection.`pipeTo​(WriteStream<Response> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | RedisConnection.`rxPipeTo​(WriteStream<Response> dst)` | Pipe this `ReadStream` to the `WriteStream`.

  - ### Uses of WriteStream in io.vertx.reactivex.sqlclient

    Methods in io.vertx.reactivex.sqlclient with parameters of type WriteStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | RowStream.`pipeTo​(WriteStream<T> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | RowStream.`rxPipeTo​(WriteStream<T> dst)` | Pipe this `ReadStream` to the `WriteStream`.