class reactor.core.publisher.FluxMetrics$MetricsSubscriber<T> implements reactor.core.publisher.InnerOperator<T, T>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: reactor.core.publisher.FluxMetrics$MetricsSubscriber
  super_class: java.lang.Object
{
  final reactor.core.CoreSubscriber<? super T> actual;
    descriptor: Lreactor/core/CoreSubscriber;
    flags: (0x0010) ACC_FINAL
    Signature: Lreactor/core/CoreSubscriber<-TT;>;

  final Clock clock;
    descriptor: LClock;
    flags: (0x0010) ACC_FINAL

  final java.lang.String sequenceName;
    descriptor: Ljava/lang/String;
    flags: (0x0010) ACC_FINAL

  final Tags commonTags;
    descriptor: LTags;
    flags: (0x0010) ACC_FINAL

  final MeterRegistry registry;
    descriptor: LMeterRegistry;
    flags: (0x0010) ACC_FINAL

  final DistributionSummary requestedCounter;
    descriptor: LDistributionSummary;
    flags: (0x0010) ACC_FINAL

  final Timer onNextIntervalTimer;
    descriptor: LTimer;
    flags: (0x0010) ACC_FINAL

  Timer.Sample subscribeToTerminateSample;
    descriptor: LTimer/Sample;
    flags: (0x0000) 

  long lastNextEventNanos;
    descriptor: J
    flags: (0x0000) 

  boolean done;
    descriptor: Z
    flags: (0x0000) 

  org.reactivestreams.Subscription s;
    descriptor: Lorg/reactivestreams/Subscription;
    flags: (0x0000) 

  void <init>(reactor.core.CoreSubscriber<? super T>, MeterRegistry, Clock, java.lang.String, Tags);
    descriptor: (Lreactor/core/CoreSubscriber;LMeterRegistry;LClock;Ljava/lang/String;LTags;)V
    flags: (0x0000) 
    Code:
      stack=3, locals=6, args_size=6
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 23
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tThe import io.micrometer cannot be resolved\n\tThe import io.micrometer cannot be resolved\n\tThe import io.micrometer cannot be resolved\n\tThe import io.micrometer cannot be resolved\n\tThe import io.micrometer cannot be resolved\n\tThe import io.micrometer cannot be resolved\n\tThe import io.micrometer cannot be resolved\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tThe method getRegistry() from the type Metrics.MicrometerConfiguration refers to the missing type MeterRegistry\n\tMeterRegistry cannot be resolved to a type\n\tClock cannot be resolved to a variable\n\tTags cannot be resolved to a type\n\tClock cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tDistributionSummary cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tClock cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tClock cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved\n\tDistributionSummary cannot be resolved to a type\n\tDistributionSummary cannot be resolved\n\tDistributionSummary cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tSample cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tSample cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tSample cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tDistributionSummary cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tTags cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved\n\tTag cannot be resolved to a type\n\tTag cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tThis lambda expression refers to the missing type Tags\n\tTag cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved\n\tTag cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved to a type\n\tTimer cannot be resolved\n\tTags cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tCounter cannot be resolved\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;
    Signature: (Lreactor/core/CoreSubscriber<-TT;>;LMeterRegistry;LClock;Ljava/lang/String;LTags;)V
    MethodParameters:
              Name  Flags
      actual        
      registry      
      clock         
      sequenceName  
      commonTags    

  public final reactor.core.CoreSubscriber<? super T> actual();
    descriptor: ()Lreactor/core/CoreSubscriber;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 123
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;
    Signature: ()Lreactor/core/CoreSubscriber<-TT;>;

  public final void cancel();
    descriptor: ()V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 131
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tSample cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;

  public final void onComplete();
    descriptor: ()V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 146
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tTimer cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tSample cannot be resolved to a type\n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n\tSample cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;

  public final void onError(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 158
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tTags cannot be resolved to a type\n\tMeterRegistry cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;
    MethodParameters:
      Name  Flags
      e     

  public void onNext();
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 172
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tTags cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;
    Signature: (TT;)V
    MethodParameters:
      Name  Flags
      t     

  public void onSubscribe(org.reactivestreams.Subscription);
    descriptor: (Lorg/reactivestreams/Subscription;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 188
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tTags cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;
    MethodParameters:
      Name  Flags
      s     

  public final void request(long);
    descriptor: (J)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 200
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tDistributionSummary cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;
    MethodParameters:
      Name  Flags
      l     

  public java.lang.Object scanUnsafe(reactor.core.Scannable$Attr);
    descriptor: (Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
         0: .line 208
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // reactor.core.publisher.FluxMetrics$MetricsSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxMetrics$MetricsSubscriber<TT;>;
    MethodParameters:
      Name  Flags
      key   
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lreactor/core/publisher/InnerOperator<TT;TT;>;
SourceFile: "FluxMetrics.java"
NestHost: reactor.core.publisher.FluxMetrics
InnerClasses:
  public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
  MetricsSubscriber = reactor.core.publisher.FluxMetrics$MetricsSubscriber of reactor.core.publisher.FluxMetrics