public interface io.vertx.reactivex.WriteStreamObserver<R> extends io.reactivex.Observer<R>
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: io.vertx.reactivex.WriteStreamObserver
super_class: java.lang.Object
{
public abstract io.vertx.reactivex.WriteStreamObserver<R> onError(io.reactivex.functions.Consumer<? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/vertx/reactivex/WriteStreamObserver;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)Lio/vertx/reactivex/WriteStreamObserver<TR;>;
MethodParameters:
Name Flags
handler
public abstract io.vertx.reactivex.WriteStreamObserver<R> onComplete(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/vertx/reactivex/WriteStreamObserver;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/reactivex/functions/Action;)Lio/vertx/reactivex/WriteStreamObserver<TR;>;
MethodParameters:
Name Flags
handler
public abstract io.vertx.reactivex.WriteStreamObserver<R> onWriteStreamError(io.reactivex.functions.Consumer<? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/vertx/reactivex/WriteStreamObserver;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)Lio/vertx/reactivex/WriteStreamObserver<TR;>;
MethodParameters:
Name Flags
handler
}
Signature: <R:Ljava/lang/Object;>Ljava/lang/Object;Lio/reactivex/Observer<TR;>;
SourceFile: "WriteStreamObserver.java"