## Uses of Interface
io.vertx.reactivex.WriteStreamObserver

- Packages that use WriteStreamObserver
  Package | Description
  --- | ---
  io.vertx.reactivex |
  io.vertx.reactivex.amqp |
  io.vertx.reactivex.core.file |
  io.vertx.reactivex.core.http |
  io.vertx.reactivex.core.net |
  io.vertx.reactivex.core.streams |
  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.producer |

- - ### Uses of WriteStreamObserver in io.vertx.reactivex

    Methods in io.vertx.reactivex that return WriteStreamObserver
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamObserver<R>` | WriteStreamObserver.`onError​(Consumer<? super Throwable> handler)` | Sets the handler to invoke if the `Observable` that was subscribed to terminates with an error.
    `WriteStreamObserver<R>` | WriteStreamObserver.`onWriteStreamEnd​(Action handler)` | Sets the handler to invoke when the adapted `WriteStream` ends successfully.
    `WriteStreamObserver<R>` | WriteStreamObserver.`onWriteStreamEndError​(Consumer<? super Throwable> handler)` | Sets the handler to invoke when the adapted `WriteStream` ends with an error.
    `WriteStreamObserver<R>` | WriteStreamObserver.`onWriteStreamError​(Consumer<? super Throwable> handler)` | Sets the handler to invoke if the adapted `WriteStream` fails.
    `static <T> WriteStreamObserver<T>` | RxHelper.`toObserver​(WriteStream<T> stream)` | Adapts a Vert.x `WriteStream` to an RxJava `Observer`.
    `static <R,​T> WriteStreamObserver<R>` | RxHelper.`toObserver​(WriteStream<T> stream, Function<R,​T> mapping)` | Like `RxHelper.toObserver(WriteStream)`, except the provided `mapping` function is applied to each `Observable` item.

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

    Methods in io.vertx.reactivex.amqp that return WriteStreamObserver
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamObserver<AmqpMessage>` | AmqpSender.`toObserver()` |

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

    Methods in io.vertx.reactivex.core.file that return WriteStreamObserver
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamObserver<Buffer>` | AsyncFile.`toObserver()` |

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

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

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

    Methods in io.vertx.reactivex.core.net that return WriteStreamObserver
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamObserver<Buffer>` | NetSocket.`toObserver()` |

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

    Methods in io.vertx.reactivex.core.streams that return WriteStreamObserver
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamObserver<T>` | WriteStream.`toObserver()` |

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

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

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

    Methods in io.vertx.reactivex.grpc.client that return WriteStreamObserver
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamObserver<Req>` | GrpcClientRequest.`toObserver()` |

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

    Methods in io.vertx.reactivex.grpc.common that return WriteStreamObserver
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamObserver<T>` | GrpcWriteStream.`toObserver()` |

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

    Methods in io.vertx.reactivex.grpc.server that return WriteStreamObserver
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStreamObserver<Resp>` | GrpcServerResponse.`toObserver()` |

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

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