Uses of Interface
io.vertx.rxjava3.WriteStreamObserver
-
-
Uses of WriteStreamObserver in io.vertx.rxjava3
Methods in io.vertx.rxjava3 that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<R>WriteStreamObserver. onError(Consumer<? super Throwable> handler)Sets the handler to invoke if theObservablethat was subscribed to terminates with an error.WriteStreamObserver<R>WriteStreamObserver. onWriteStreamEnd(Action handler)Sets the handler to invoke when the adaptedWriteStreamends successfully.WriteStreamObserver<R>WriteStreamObserver. onWriteStreamEndError(Consumer<? super Throwable> handler)Sets the handler to invoke when the adaptedWriteStreamends with an error.WriteStreamObserver<R>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, java.util.function.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 Modifier and Type Method Description WriteStreamObserver<AmqpMessage>AmqpSender. toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.core.file
Methods in io.vertx.rxjava3.core.file that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<Buffer>AsyncFile. toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.core.http
Methods in io.vertx.rxjava3.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.rxjava3.core.net
Methods in io.vertx.rxjava3.core.net that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<Buffer>NetSocket. toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.core.streams
Methods in io.vertx.rxjava3.core.streams that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<T>WriteStream. toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.ext.web.handler.sockjs
Methods in io.vertx.rxjava3.ext.web.handler.sockjs that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<Buffer>SockJSSocket. toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.grpc.client
Methods in io.vertx.rxjava3.grpc.client that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<Req>GrpcClientRequest. toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.grpc.common
Methods in io.vertx.rxjava3.grpc.common that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<T>GrpcWriteStream. toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.grpc.server
Methods in io.vertx.rxjava3.grpc.server that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<Resp>GrpcServerResponse. toObserver() -
Uses of WriteStreamObserver in io.vertx.rxjava3.kafka.client.producer
Methods in io.vertx.rxjava3.kafka.client.producer that return WriteStreamObserver Modifier and Type Method Description WriteStreamObserver<KafkaProducerRecord<K,V>>KafkaProducer. toObserver()
-