Uses of Interface
io.vertx.rxjava3.WriteStreamObserver
Packages that use WriteStreamObserver
Package
Description
-
Uses of WriteStreamObserver in io.vertx.rxjava3
Methods in io.vertx.rxjava3 that return WriteStreamObserverModifier and TypeMethodDescriptionSets the handler to invoke if theObservablethat was subscribed to terminates with an error.WriteStreamObserver.onWriteStreamEnd(Action handler) Sets the handler to invoke when the adaptedWriteStreamends successfully.WriteStreamObserver.onWriteStreamEndError(Consumer<? super Throwable> handler) Sets the handler to invoke when the adaptedWriteStreamends with an error.WriteStreamObserver.onWriteStreamError(Consumer<? super Throwable> handler) Sets the handler to invoke if the adaptedWriteStreamfails.static <T> WriteStreamObserver<T> RxHelper.toObserver(WriteStream<T> stream) Adapts a Vert.xWriteStreamto an RxJavaObserver.static <R,T> WriteStreamObserver <R> RxHelper.toObserver(WriteStream<T> stream, Function<R, T> mapping) LikeRxHelper.toObserver(WriteStream), except the providedmappingfunction is applied to eachObservableitem. -
Uses of WriteStreamObserver in io.vertx.rxjava3.amqp
Methods in io.vertx.rxjava3.amqp that return WriteStreamObserver -
Uses of WriteStreamObserver in io.vertx.rxjava3.core.file
Methods in io.vertx.rxjava3.core.file that return WriteStreamObserver -
Uses of WriteStreamObserver in io.vertx.rxjava3.core.http
Methods in io.vertx.rxjava3.core.http that return WriteStreamObserverModifier and TypeMethodDescriptionClientWebSocket.toObserver()HttpClientRequest.toObserver()HttpServerResponse.toObserver()ServerWebSocket.toObserver()WebSocket.toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.core.net
Methods in io.vertx.rxjava3.core.net that return WriteStreamObserver -
Uses of WriteStreamObserver in io.vertx.rxjava3.core.streams
Methods in io.vertx.rxjava3.core.streams that return WriteStreamObserver -
Uses of WriteStreamObserver in io.vertx.rxjava3.ext.web.handler.sockjs
Methods in io.vertx.rxjava3.ext.web.handler.sockjs that return WriteStreamObserver -
Uses of WriteStreamObserver in io.vertx.rxjava3.grpc.client
Methods in io.vertx.rxjava3.grpc.client that return WriteStreamObserver -
Uses of WriteStreamObserver in io.vertx.rxjava3.grpc.common
Methods in io.vertx.rxjava3.grpc.common that return WriteStreamObserver -
Uses of WriteStreamObserver in io.vertx.rxjava3.grpc.server
Methods in io.vertx.rxjava3.grpc.server that return WriteStreamObserver -
Uses of WriteStreamObserver in io.vertx.rxjava3.kafka.client.producer
Methods in io.vertx.rxjava3.kafka.client.producer that return WriteStreamObserver