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