final class reactor.core.publisher.FluxMetrics<T> extends reactor.core.publisher.InternalFluxOperator<T, T>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.FluxMetrics
super_class: reactor.core.publisher.InternalFluxOperator
{
final java.lang.String name;
descriptor: Ljava/lang/String;
flags: (0x0010) ACC_FINAL
final Tags tags;
descriptor: LTags;
flags: (0x0010) ACC_FINAL
final MeterRegistry registryCandidate;
descriptor: LMeterRegistry;
flags: (0x0010) ACC_FINAL
static final java.lang.String REACTOR_DEFAULT_NAME;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "reactor"
static final java.lang.String METER_MALFORMED;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: ".malformed.source"
static final java.lang.String METER_SUBSCRIBED;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: ".subscribed"
static final java.lang.String METER_FLOW_DURATION;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: ".flow.duration"
static final java.lang.String METER_ON_NEXT_DELAY;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: ".onNext.delay"
static final java.lang.String METER_REQUESTED;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: ".requested"
static final java.lang.String TAG_KEY_EXCEPTION;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "exception"
static final Tags DEFAULT_TAGS_FLUX;
descriptor: LTags;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final Tags DEFAULT_TAGS_MONO;
descriptor: LTags;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final Tag TAG_ON_ERROR;
descriptor: LTag;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final Tags TAG_ON_COMPLETE;
descriptor: LTags;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final Tags TAG_ON_COMPLETE_EMPTY;
descriptor: LTags;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final Tags TAG_CANCEL;
descriptor: LTags;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final reactor.util.Logger log;
descriptor: Lreactor/util/Logger;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final java.util.function.BiFunction<Tags, reactor.util.function.Tuple2<java.lang.String, java.lang.String>, Tags> TAG_ACCUMULATOR;
descriptor: Ljava/util/function/BiFunction;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/function/BiFunction<LTags;Lreactor/util/function/Tuple2<Ljava/lang/String;Ljava/lang/String;>;LTags;>;
static final java.util.function.BinaryOperator<Tags> TAG_COMBINER;
descriptor: Ljava/util/function/BinaryOperator;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/function/BinaryOperator<LTags;>;
void <init>(reactor.core.publisher.Flux<? extends T>);
descriptor: (Lreactor/core/publisher/Flux;)V
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 0: 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 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxMetrics<TT;>;
Signature: (Lreactor/core/publisher/Flux<+TT;>;)V
MethodParameters:
Name Flags
flux
public reactor.core.CoreSubscriber<? super T> subscribeOrReturn(reactor.core.CoreSubscriber<? super T>);
descriptor: (Lreactor/core/CoreSubscriber;)Lreactor/core/CoreSubscriber;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \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"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxMetrics<TT;>;
Signature: (Lreactor/core/CoreSubscriber<-TT;>;)Lreactor/core/CoreSubscriber<-TT;>;
MethodParameters:
Name Flags
actual
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 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxMetrics<TT;>;
MethodParameters:
Name Flags
key
static java.lang.String resolveName(org.reactivestreams.Publisher<?>);
descriptor: (Lorg/reactivestreams/Publisher;)Ljava/lang/String;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=1, args_size=1
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: (Lorg/reactivestreams/Publisher<*>;)Ljava/lang/String;
MethodParameters:
Name Flags
source
static Tags resolveTags(org.reactivestreams.Publisher<?>, Tags);
descriptor: (Lorg/reactivestreams/Publisher;LTags;)LTags;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=2, args_size=2
0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \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"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: (Lorg/reactivestreams/Publisher<*>;LTags;)LTags;
MethodParameters:
Name Flags
source
tags
static void recordCancel(java.lang.String, Tags, MeterRegistry, Timer.Sample);
descriptor: (Ljava/lang/String;LTags;LMeterRegistry;LTimer/Sample;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=4, args_size=4
0: 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\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"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
MethodParameters:
Name Flags
name
commonTags
registry
flowDuration
static void recordMalformed(java.lang.String, Tags, MeterRegistry);
descriptor: (Ljava/lang/String;LTags;LMeterRegistry;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=3, args_size=3
0: 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
LocalVariableTable:
Start End Slot Name Signature
MethodParameters:
Name Flags
name
commonTags
registry
static void recordOnError(java.lang.String, Tags, MeterRegistry, Timer.Sample, java.lang.Throwable);
descriptor: (Ljava/lang/String;LTags;LMeterRegistry;LTimer/Sample;Ljava/lang/Throwable;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=5, args_size=5
0: 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\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"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
MethodParameters:
Name Flags
name
commonTags
registry
flowDuration
e
static void recordOnComplete(java.lang.String, Tags, MeterRegistry, Timer.Sample);
descriptor: (Ljava/lang/String;LTags;LMeterRegistry;LTimer/Sample;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=4, args_size=4
0: 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\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"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
MethodParameters:
Name Flags
name
commonTags
registry
flowDuration
static void recordOnCompleteEmpty(java.lang.String, Tags, MeterRegistry, Timer.Sample);
descriptor: (Ljava/lang/String;LTags;LMeterRegistry;LTimer/Sample;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=4, args_size=4
0: 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\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"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
MethodParameters:
Name Flags
name
commonTags
registry
flowDuration
static void recordOnSubscribe(java.lang.String, Tags, MeterRegistry);
descriptor: (Ljava/lang/String;LTags;LMeterRegistry;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=3, args_size=3
0: 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\tCounter cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
MethodParameters:
Name Flags
name
commonTags
registry
}
Signature: <T:Ljava/lang/Object;>Lreactor/core/publisher/InternalFluxOperator<TT;TT;>;
SourceFile: "FluxMetrics.java"
NestMembers:
reactor.core.publisher.FluxMetrics$MetricsSubscriber
InnerClasses:
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
MetricsSubscriber = reactor.core.publisher.FluxMetrics$MetricsSubscriber of reactor.core.publisher.FluxMetrics
FluxMetrics
scanUnsafe(Scannable$Attr): Object