interface reactor.core.publisher.OptimizableOperator<IN, OUT> extends reactor.core.CorePublisher<IN>
minor version: 0
major version: 59
flags: flags: (0x0600) ACC_INTERFACE, ACC_ABSTRACT
this_class: reactor.core.publisher.OptimizableOperator
super_class: java.lang.Object
{
public abstract reactor.core.CoreSubscriber<? super OUT> subscribeOrReturn(reactor.core.CoreSubscriber<? super IN>);
descriptor: (Lreactor/core/CoreSubscriber;)Lreactor/core/CoreSubscriber;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Exceptions:
throws java.lang.Throwable
Signature: (Lreactor/core/CoreSubscriber<-TIN;>;)Lreactor/core/CoreSubscriber<-TOUT;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
actual
public abstract reactor.core.CorePublisher<? extends OUT> source();
descriptor: ()Lreactor/core/CorePublisher;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: ()Lreactor/core/CorePublisher<+TOUT;>;
public abstract reactor.core.publisher.OptimizableOperator<?, ? extends OUT> nextOptimizableSource();
descriptor: ()Lreactor/core/publisher/OptimizableOperator;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: ()Lreactor/core/publisher/OptimizableOperator<*+TOUT;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
}
Signature: <IN:Ljava/lang/Object;OUT:Ljava/lang/Object;>Ljava/lang/Object;Lreactor/core/CorePublisher<TIN;>;
SourceFile: "OptimizableOperator.java"