interface reactor.core.publisher.SignalPeek<T> extends reactor.core.Scannable
  minor version: 0
  major version: 59
  flags: flags: (0x0600) ACC_INTERFACE, ACC_ABSTRACT
  this_class: reactor.core.publisher.SignalPeek
  super_class: java.lang.Object
{
  public abstract java.util.function.Consumer<? super org.reactivestreams.Subscription> onSubscribeCall();
    descriptor: ()Ljava/util/function/Consumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Ljava/util/function/Consumer<-Lorg/reactivestreams/Subscription;>;
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public abstract java.util.function.Consumer<? super T> onNextCall();
    descriptor: ()Ljava/util/function/Consumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Ljava/util/function/Consumer<-TT;>;
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public abstract java.util.function.Consumer<? super java.lang.Throwable> onErrorCall();
    descriptor: ()Ljava/util/function/Consumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Ljava/util/function/Consumer<-Ljava/lang/Throwable;>;
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public abstract java.lang.Runnable onCompleteCall();
    descriptor: ()Ljava/lang/Runnable;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public abstract java.lang.Runnable onAfterTerminateCall();
    descriptor: ()Ljava/lang/Runnable;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public abstract java.util.function.LongConsumer onRequestCall();
    descriptor: ()Ljava/util/function/LongConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public abstract java.lang.Runnable onCancelCall();
    descriptor: ()Ljava/lang/Runnable;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public java.util.function.Consumer<? super T> onAfterNextCall();
    descriptor: ()Ljava/util/function/Consumer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.core.publisher.SignalPeek this
         0: .line 98
            aconst_null
            areturn
        end local 0 // reactor.core.publisher.SignalPeek this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/SignalPeek<TT;>;
    Signature: ()Ljava/util/function/Consumer<-TT;>;
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public java.util.function.Consumer<? super reactor.util.context.Context> onCurrentContextCall();
    descriptor: ()Ljava/util/function/Consumer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.core.publisher.SignalPeek this
         0: .line 107
            aconst_null
            areturn
        end local 0 // reactor.core.publisher.SignalPeek this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/SignalPeek<TT;>;
    Signature: ()Ljava/util/function/Consumer<-Lreactor/util/context/Context;>;
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lreactor/core/Scannable;
SourceFile: "SignalPeek.java"