## Uses of Class
io.vertx.rx.java.WriteStreamSubscriber

- Packages that use WriteStreamSubscriber
  Package | Description
  --- | ---
  io.vertx.rx.java |
  io.vertx.rxjava.amqp |
  io.vertx.rxjava.core.file |
  io.vertx.rxjava.core.http |
  io.vertx.rxjava.core.net |
  io.vertx.rxjava.core.streams |
  io.vertx.rxjava.ext.web.handler.sockjs |
  io.vertx.rxjava.grpc.client |
  io.vertx.rxjava.grpc.common |
  io.vertx.rxjava.grpc.server |
  io.vertx.rxjava.kafka.client.producer |

- - ### Uses of WriteStreamSubscriber in io.vertx.rx.java

    Methods in io.vertx.rx.java that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `abstract WriteStreamSubscriber<R>` | WriteStreamSubscriber.`onError​(Action1<Throwable> handler)` | Sets the handler to invoke if the `Observable` that was subscribed to terminates with an error.
    `abstract WriteStreamSubscriber<R>` | WriteStreamSubscriber.`onWriteStreamEnd​(Action0 handler)` | Sets the handler to invoke when the adapted `WriteStream` ends successfully.
    `abstract WriteStreamSubscriber<R>` | WriteStreamSubscriber.`onWriteStreamEndError​(Action1<Throwable> handler)` | Sets the handler to invoke when the adapted `WriteStream` ends with an error.
    `abstract WriteStreamSubscriber<R>` | WriteStreamSubscriber.`onWriteStreamError​(Action1<Throwable> handler)` | Sets the handler to invoke if the adapted `WriteStream` fails.
    `static <T> WriteStreamSubscriber<T>` | RxHelper.`toSubscriber​(WriteStream<T> stream)` | Adapts a Vert.x `WriteStream` to an RxJava `Subscriber`.
    `static <R,​T> WriteStreamSubscriber<R>` | RxHelper.`toSubscriber​(WriteStream<T> stream, java.util.function.Function<R,​T> mapping)` | Like `RxHelper.toSubscriber(WriteStream)`, except the provided `mapping` function is applied to each `Observable` item.

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.amqp

    Methods in io.vertx.rxjava.amqp that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<AmqpMessage>` | AmqpSender.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.core.file

    Methods in io.vertx.rxjava.core.file that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<Buffer>` | AsyncFile.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.core.http

    Methods in io.vertx.rxjava.core.http that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<Buffer>` | ClientWebSocket.`toSubscriber()` |
    `WriteStreamSubscriber<Buffer>` | HttpClientRequest.`toSubscriber()` |
    `WriteStreamSubscriber<Buffer>` | HttpServerResponse.`toSubscriber()` |
    `WriteStreamSubscriber<Buffer>` | ServerWebSocket.`toSubscriber()` |
    `WriteStreamSubscriber<Buffer>` | WebSocket.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.core.net

    Methods in io.vertx.rxjava.core.net that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<Buffer>` | NetSocket.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.core.streams

    Methods in io.vertx.rxjava.core.streams that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<T>` | WriteStream.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.ext.web.handler.sockjs

    Methods in io.vertx.rxjava.ext.web.handler.sockjs that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<Buffer>` | SockJSSocket.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.grpc.client

    Methods in io.vertx.rxjava.grpc.client that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<Req>` | GrpcClientRequest.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.grpc.common

    Methods in io.vertx.rxjava.grpc.common that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<T>` | GrpcWriteStream.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.grpc.server

    Methods in io.vertx.rxjava.grpc.server that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<Resp>` | GrpcServerResponse.`toSubscriber()` |

  - ### Uses of WriteStreamSubscriber in io.vertx.rxjava.kafka.client.producer

    Methods in io.vertx.rxjava.kafka.client.producer that return WriteStreamSubscriber
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamSubscriber<KafkaProducerRecord<K,​V>>` | KafkaProducer.`toSubscriber()` |