public final class reactor.util.retry.RetryBackoffSpec extends reactor.util.retry.Retry
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: reactor.util.retry.RetryBackoffSpec
super_class: reactor.util.retry.Retry
{
static final java.util.function.BiFunction<reactor.util.retry.RetryBackoffSpec, reactor.util.retry.Retry$RetrySignal, java.lang.Throwable> BACKOFF_EXCEPTION_GENERATOR;
descriptor: Ljava/util/function/BiFunction;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/function/BiFunction<Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;Ljava/lang/Throwable;>;
public final java.time.Duration minBackoff;
descriptor: Ljava/time/Duration;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final java.time.Duration maxBackoff;
descriptor: Ljava/time/Duration;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final double jitterFactor;
descriptor: D
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final java.util.function.Supplier<reactor.core.scheduler.Scheduler> backoffSchedulerSupplier;
descriptor: Ljava/util/function/Supplier;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Ljava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;
public final long maxAttempts;
descriptor: J
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final java.util.function.Predicate<java.lang.Throwable> errorFilter;
descriptor: Ljava/util/function/Predicate;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Ljava/util/function/Predicate<Ljava/lang/Throwable;>;
public final boolean isTransientErrors;
descriptor: Z
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
final java.util.function.Consumer<reactor.util.retry.Retry$RetrySignal> syncPreRetry;
descriptor: Ljava/util/function/Consumer;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;
final java.util.function.Consumer<reactor.util.retry.Retry$RetrySignal> syncPostRetry;
descriptor: Ljava/util/function/Consumer;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;
final java.util.function.BiFunction<reactor.util.retry.Retry$RetrySignal, reactor.core.publisher.Mono<java.lang.Void>, reactor.core.publisher.Mono<java.lang.Void>> asyncPreRetry;
descriptor: Ljava/util/function/BiFunction;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/BiFunction<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;
final java.util.function.BiFunction<reactor.util.retry.Retry$RetrySignal, reactor.core.publisher.Mono<java.lang.Void>, reactor.core.publisher.Mono<java.lang.Void>> asyncPostRetry;
descriptor: Ljava/util/function/BiFunction;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/BiFunction<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;
final java.util.function.BiFunction<reactor.util.retry.RetryBackoffSpec, reactor.util.retry.Retry$RetrySignal, java.lang.Throwable> retryExhaustedGenerator;
descriptor: Ljava/util/function/BiFunction;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/BiFunction<Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;Ljava/lang/Throwable;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokedynamic apply()Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
reactor/util/retry/RetryBackoffSpec.lambda$0(Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;)Ljava/lang/Throwable; (6)
(Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;)Ljava/lang/Throwable;
putstatic reactor.util.retry.RetryBackoffSpec.BACKOFF_EXCEPTION_GENERATOR:Ljava/util/function/BiFunction;
1: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(reactor.util.context.ContextView, long, java.util.function.Predicate<? super java.lang.Throwable>, boolean, java.time.Duration, java.time.Duration, double, java.util.function.Supplier<reactor.core.scheduler.Scheduler>, java.util.function.Consumer<reactor.util.retry.Retry$RetrySignal>, java.util.function.Consumer<reactor.util.retry.Retry$RetrySignal>, java.util.function.BiFunction<reactor.util.retry.Retry$RetrySignal, reactor.core.publisher.Mono<java.lang.Void>, reactor.core.publisher.Mono<java.lang.Void>>, java.util.function.BiFunction<reactor.util.retry.Retry$RetrySignal, reactor.core.publisher.Mono<java.lang.Void>, reactor.core.publisher.Mono<java.lang.Void>>, java.util.function.BiFunction<reactor.util.retry.RetryBackoffSpec, reactor.util.retry.Retry$RetrySignal, java.lang.Throwable>);
descriptor: (Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
flags: (0x0000)
Code:
stack=3, locals=16, args_size=14
start local 0 start local 1 start local 2 start local 4 start local 5 start local 6 start local 7 start local 8 start local 10 start local 11 start local 12 start local 13 start local 14 start local 15 0: aload 0
aload 1
invokespecial reactor.util.retry.Retry.<init>:(Lreactor/util/context/ContextView;)V
1: aload 0
lload 2
putfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
2: aload 0
aload 4
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic test(Ljava/util/function/Predicate;)Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
java/util/function/Predicate.test(Ljava/lang/Object;)Z (9 itf)
(Ljava/lang/Throwable;)Z
putfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
3: aload 0
iload 5
putfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
4: aload 0
aload 6
putfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
5: aload 0
aload 7
putfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
6: aload 0
dload 8
putfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
7: aload 0
aload 10
putfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
8: aload 0
aload 11
putfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
9: aload 0
aload 12
putfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
10: aload 0
aload 13
putfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
11: aload 0
aload 14
putfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
12: aload 0
aload 15
putfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
13: return
end local 15 end local 14 end local 13 end local 12 end local 11 end local 10 end local 8 end local 7 end local 6 end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lreactor/util/retry/RetryBackoffSpec;
0 14 1 retryContext Lreactor/util/context/ContextView;
0 14 2 max J
0 14 4 aThrowablePredicate Ljava/util/function/Predicate<-Ljava/lang/Throwable;>;
0 14 5 isTransientErrors Z
0 14 6 minBackoff Ljava/time/Duration;
0 14 7 maxBackoff Ljava/time/Duration;
0 14 8 jitterFactor D
0 14 10 backoffSchedulerSupplier Ljava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;
0 14 11 doPreRetry Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;
0 14 12 doPostRetry Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;
0 14 13 asyncPreRetry Ljava/util/function/BiFunction<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;
0 14 14 asyncPostRetry Ljava/util/function/BiFunction<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;
0 14 15 retryExhaustedGenerator Ljava/util/function/BiFunction<Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;Ljava/lang/Throwable;>;
Signature: (Lreactor/util/context/ContextView;JLjava/util/function/Predicate<-Ljava/lang/Throwable;>;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;Ljava/util/function/BiFunction<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;Ljava/util/function/BiFunction<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;Ljava/util/function/BiFunction<Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;Ljava/lang/Throwable;>;)V
MethodParameters:
Name Flags
retryContext
max
aThrowablePredicate
isTransientErrors
minBackoff
maxBackoff
jitterFactor
backoffSchedulerSupplier
doPreRetry
doPostRetry
asyncPreRetry
asyncPostRetry
retryExhaustedGenerator
public reactor.util.retry.RetryBackoffSpec withRetryContext(reactor.util.context.ContextView);
descriptor: (Lreactor/util/context/ContextView;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 1
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 retryContext Lreactor/util/context/ContextView;
MethodParameters:
Name Flags
retryContext
public reactor.util.retry.RetryBackoffSpec maxAttempts(long);
descriptor: (J)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=3, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: lload 1
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 maxAttempts J
MethodParameters:
Name Flags
maxAttempts
public reactor.util.retry.RetryBackoffSpec filter(java.util.function.Predicate<? super java.lang.Throwable>);
descriptor: (Ljava/util/function/Predicate;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 1
ldc "errorFilter"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Predicate
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 errorFilter Ljava/util/function/Predicate<-Ljava/lang/Throwable;>;
Signature: (Ljava/util/function/Predicate<-Ljava/lang/Throwable;>;)Lreactor/util/retry/RetryBackoffSpec;
MethodParameters:
Name Flags
errorFilter
public reactor.util.retry.RetryBackoffSpec modifyErrorFilter(java.util.function.Function<java.util.function.Predicate<java.lang.Throwable>, java.util.function.Predicate<? super java.lang.Throwable>>);
descriptor: (Ljava/util/function/Function;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc "predicateAdjuster"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.function.Predicate
2: ldc "predicateAdjuster must return a new predicate"
3: invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Predicate
astore 2
start local 2 4: new reactor.util.retry.RetryBackoffSpec
dup
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
7: aload 2
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
14: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
15: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
16: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
17: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
18: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lreactor/util/retry/RetryBackoffSpec;
0 19 1 predicateAdjuster Ljava/util/function/Function<Ljava/util/function/Predicate<Ljava/lang/Throwable;>;Ljava/util/function/Predicate<-Ljava/lang/Throwable;>;>;
4 19 2 newPredicate Ljava/util/function/Predicate<-Ljava/lang/Throwable;>;
Signature: (Ljava/util/function/Function<Ljava/util/function/Predicate<Ljava/lang/Throwable;>;Ljava/util/function/Predicate<-Ljava/lang/Throwable;>;>;)Lreactor/util/retry/RetryBackoffSpec;
MethodParameters:
Name Flags
predicateAdjuster
public reactor.util.retry.RetryBackoffSpec doBeforeRetry(java.util.function.Consumer<reactor.util.retry.Retry$RetrySignal>);
descriptor: (Ljava/util/function/Consumer;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
aload 1
invokeinterface java.util.function.Consumer.andThen:(Ljava/util/function/Consumer;)Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 doBeforeRetry Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;
Signature: (Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;)Lreactor/util/retry/RetryBackoffSpec;
MethodParameters:
Name Flags
doBeforeRetry
public reactor.util.retry.RetryBackoffSpec doAfterRetry(java.util.function.Consumer<reactor.util.retry.Retry$RetrySignal>);
descriptor: (Ljava/util/function/Consumer;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
aload 1
invokeinterface java.util.function.Consumer.andThen:(Ljava/util/function/Consumer;)Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 doAfterRetry Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;
Signature: (Ljava/util/function/Consumer<Lreactor/util/retry/Retry$RetrySignal;>;)Lreactor/util/retry/RetryBackoffSpec;
MethodParameters:
Name Flags
doAfterRetry
public reactor.util.retry.RetryBackoffSpec doBeforeRetryAsync(java.util.function.Function<reactor.util.retry.Retry$RetrySignal, reactor.core.publisher.Mono<java.lang.Void>>);
descriptor: (Ljava/util/function/Function;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
aload 1
invokedynamic apply(Lreactor/util/retry/RetryBackoffSpec;Ljava/util/function/Function;)Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
reactor/util/retry/RetryBackoffSpec.lambda$2(Ljava/util/function/Function;Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono; (7)
(Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 doAsyncBeforeRetry Ljava/util/function/Function<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;
Signature: (Ljava/util/function/Function<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;)Lreactor/util/retry/RetryBackoffSpec;
MethodParameters:
Name Flags
doAsyncBeforeRetry
public reactor.util.retry.RetryBackoffSpec doAfterRetryAsync(java.util.function.Function<reactor.util.retry.Retry$RetrySignal, reactor.core.publisher.Mono<java.lang.Void>>);
descriptor: (Ljava/util/function/Function;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
aload 1
invokedynamic apply(Lreactor/util/retry/RetryBackoffSpec;Ljava/util/function/Function;)Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
reactor/util/retry/RetryBackoffSpec.lambda$3(Ljava/util/function/Function;Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono; (7)
(Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 doAsyncAfterRetry Ljava/util/function/Function<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;
Signature: (Ljava/util/function/Function<Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;)Lreactor/util/retry/RetryBackoffSpec;
MethodParameters:
Name Flags
doAsyncAfterRetry
public reactor.util.retry.RetryBackoffSpec onRetryExhaustedThrow(java.util.function.BiFunction<reactor.util.retry.RetryBackoffSpec, reactor.util.retry.Retry$RetrySignal, java.lang.Throwable>);
descriptor: (Ljava/util/function/BiFunction;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=18, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 1
ldc "retryExhaustedGenerator"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.BiFunction
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 retryExhaustedGenerator Ljava/util/function/BiFunction<Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;Ljava/lang/Throwable;>;
Signature: (Ljava/util/function/BiFunction<Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;Ljava/lang/Throwable;>;)Lreactor/util/retry/RetryBackoffSpec;
MethodParameters:
Name Flags
retryExhaustedGenerator
public reactor.util.retry.RetryBackoffSpec transientErrors(boolean);
descriptor: (Z)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: iload 1
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 isTransientErrors Z
MethodParameters:
Name Flags
isTransientErrors
public reactor.util.retry.RetryBackoffSpec minBackoff(java.time.Duration);
descriptor: (Ljava/time/Duration;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 1
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 minBackoff Ljava/time/Duration;
MethodParameters:
Name Flags
minBackoff
public reactor.util.retry.RetryBackoffSpec maxBackoff(java.time.Duration);
descriptor: (Ljava/time/Duration;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 1
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 maxBackoff Ljava/time/Duration;
MethodParameters:
Name Flags
maxBackoff
public reactor.util.retry.RetryBackoffSpec jitter(double);
descriptor: (D)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=3, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: dload 1
8: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
9: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
14: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/util/retry/RetryBackoffSpec;
0 15 1 jitterFactor D
MethodParameters:
Name Flags
jitterFactor
public reactor.util.retry.RetryBackoffSpec scheduler(reactor.core.scheduler.Scheduler);
descriptor: (Lreactor/core/scheduler/Scheduler;)Lreactor/util/retry/RetryBackoffSpec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=17, locals=2, args_size=2
start local 0 start local 1 0: new reactor.util.retry.RetryBackoffSpec
dup
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryContext:Lreactor/util/context/ContextView;
2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
3: aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
4: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
5: aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
6: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
7: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
8: aload 1
ifnonnull 9
invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
reactor/core/scheduler/Schedulers.parallel()Lreactor/core/scheduler/Scheduler; (6)
()Lreactor/core/scheduler/Scheduler;
goto 10
StackMap locals: reactor.util.retry.RetryBackoffSpec reactor.core.scheduler.Scheduler
StackMap stack: new 0 new 0 reactor.util.context.ContextView long java.util.function.Predicate int java.time.Duration java.time.Duration double
9: aload 1
invokedynamic get(Lreactor/core/scheduler/Scheduler;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
reactor/util/retry/RetryBackoffSpec.lambda$5(Lreactor/core/scheduler/Scheduler;)Lreactor/core/scheduler/Scheduler; (6)
()Lreactor/core/scheduler/Scheduler;
10: StackMap locals: reactor.util.retry.RetryBackoffSpec reactor.core.scheduler.Scheduler
StackMap stack: new 0 new 0 reactor.util.context.ContextView long java.util.function.Predicate int java.time.Duration java.time.Duration double java.util.function.Supplier
aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
11: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
12: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
14: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
15: invokespecial reactor.util.retry.RetryBackoffSpec.<init>:(Lreactor/util/context/ContextView;JLjava/util/function/Predicate;ZLjava/time/Duration;Ljava/time/Duration;DLjava/util/function/Supplier;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lreactor/util/retry/RetryBackoffSpec;
0 16 1 backoffScheduler Lreactor/core/scheduler/Scheduler;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
backoffScheduler
protected void validateArguments();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
dconst_0
dcmpg
iflt 1
aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
dconst_1
dcmpl
ifle 2
StackMap locals:
StackMap stack:
1: new java.lang.IllegalArgumentException
dup
ldc "jitterFactor must be between 0 and 1 (default 0.5)"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/util/retry/RetryBackoffSpec;
public reactor.core.publisher.Flux<java.lang.Long> generateCompanion(reactor.core.publisher.Flux<reactor.util.retry.Retry$RetrySignal>);
descriptor: (Lreactor/core/publisher/Flux;)Lreactor/core/publisher/Flux;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual reactor.util.retry.RetryBackoffSpec.validateArguments:()V
1: aload 1
aload 0
invokedynamic apply(Lreactor/util/retry/RetryBackoffSpec;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
reactor/util/retry/RetryBackoffSpec.lambda$6(Lreactor/util/retry/Retry$RetrySignal;)Lorg/reactivestreams/Publisher; (7)
(Lreactor/util/retry/Retry$RetrySignal;)Lorg/reactivestreams/Publisher;
invokevirtual reactor.core.publisher.Flux.concatMap:(Ljava/util/function/Function;)Lreactor/core/publisher/Flux;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/util/retry/RetryBackoffSpec;
0 2 1 t Lreactor/core/publisher/Flux<Lreactor/util/retry/Retry$RetrySignal;>;
Signature: (Lreactor/core/publisher/Flux<Lreactor/util/retry/Retry$RetrySignal;>;)Lreactor/core/publisher/Flux<Ljava/lang/Long;>;
MethodParameters:
Name Flags
t
public org.reactivestreams.Publisher generateCompanion(reactor.core.publisher.Flux);
descriptor: (Lreactor/core/publisher/Flux;)Lorg/reactivestreams/Publisher;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual reactor.util.retry.RetryBackoffSpec.generateCompanion:(Lreactor/core/publisher/Flux;)Lreactor/core/publisher/Flux;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.Throwable lambda$0(reactor.util.retry.RetryBackoffSpec, reactor.util.retry.Retry$RetrySignal);
descriptor: (Lreactor/util/retry/RetryBackoffSpec;Lreactor/util/retry/Retry$RetrySignal;)Ljava/lang/Throwable;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: new java.lang.StringBuilder
dup
ldc "Retries exhausted: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
1: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
ifeq 3
2: new java.lang.StringBuilder
dup
aload 1
invokeinterface reactor.util.retry.Retry$RetrySignal.totalRetriesInARow:()J
invokestatic java.lang.String.valueOf:(J)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "/"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " in a row ("
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokeinterface reactor.util.retry.Retry$RetrySignal.totalRetries:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " total)"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
goto 4
3: StackMap locals:
StackMap stack: java.lang.StringBuilder
new java.lang.StringBuilder
dup
aload 1
invokeinterface reactor.util.retry.Retry$RetrySignal.totalRetries:()J
invokestatic java.lang.String.valueOf:(J)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "/"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
4: StackMap locals: reactor.util.retry.RetryBackoffSpec reactor.util.retry.Retry$RetrySignal
StackMap stack: java.lang.StringBuilder java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
5: aload 1
invokeinterface reactor.util.retry.Retry$RetrySignal.failure:()Ljava/lang/Throwable;
6: invokestatic reactor.core.Exceptions.retryExhausted:(Ljava/lang/String;Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
7: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 builder Lreactor/util/retry/RetryBackoffSpec;
0 8 1 rs Lreactor/util/retry/Retry$RetrySignal;
private reactor.core.publisher.Mono lambda$2(java.util.function.Function, reactor.util.retry.Retry$RetrySignal, reactor.core.publisher.Mono);
descriptor: (Ljava/util/function/Function;Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 2 start local 3 0: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
aload 2
aload 3
invokeinterface java.util.function.BiFunction.apply:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.Mono
aload 1
aload 2
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.Mono
invokevirtual reactor.core.publisher.Mono.then:(Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
areturn
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/util/retry/RetryBackoffSpec;
0 1 2 rs Lreactor/util/retry/Retry$RetrySignal;
0 1 3 m Lreactor/core/publisher/Mono<Ljava/lang/Void;>;
private reactor.core.publisher.Mono lambda$3(java.util.function.Function, reactor.util.retry.Retry$RetrySignal, reactor.core.publisher.Mono);
descriptor: (Ljava/util/function/Function;Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 2 start local 3 0: aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
aload 2
aload 3
invokeinterface java.util.function.BiFunction.apply:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.Mono
aload 1
aload 2
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.Mono
invokevirtual reactor.core.publisher.Mono.then:(Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
areturn
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/util/retry/RetryBackoffSpec;
0 1 2 rs Lreactor/util/retry/Retry$RetrySignal;
0 1 3 m Lreactor/core/publisher/Mono<Ljava/lang/Void;>;
private static reactor.core.scheduler.Scheduler lambda$5(reactor.core.scheduler.Scheduler);
descriptor: (Lreactor/core/scheduler/Scheduler;)Lreactor/core/scheduler/Scheduler;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
areturn
LocalVariableTable:
Start End Slot Name Signature
private org.reactivestreams.Publisher lambda$6(reactor.util.retry.Retry$RetrySignal);
descriptor: (Lreactor/util/retry/Retry$RetrySignal;)Lorg/reactivestreams/Publisher;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=17, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface reactor.util.retry.Retry$RetrySignal.copy:()Lreactor/util/retry/Retry$RetrySignal;
astore 2
start local 2 1: aload 2
invokeinterface reactor.util.retry.Retry$RetrySignal.failure:()Ljava/lang/Throwable;
astore 3
start local 3 2: aload 0
getfield reactor.util.retry.RetryBackoffSpec.isTransientErrors:Z
ifeq 3
aload 2
invokeinterface reactor.util.retry.Retry$RetrySignal.totalRetriesInARow:()J
goto 4
StackMap locals: reactor.util.retry.Retry$RetrySignal java.lang.Throwable
StackMap stack:
3: aload 2
invokeinterface reactor.util.retry.Retry$RetrySignal.totalRetries:()J
StackMap locals:
StackMap stack: long
4: lstore 4
start local 4 5: aload 3
ifnonnull 7
6: new java.lang.IllegalStateException
dup
ldc "Retry.RetrySignal#failure() not expected to be null"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
invokestatic reactor.core.publisher.Mono.error:(Ljava/lang/Throwable;)Lreactor/core/publisher/Mono;
areturn
7: StackMap locals: long
StackMap stack:
aload 0
getfield reactor.util.retry.RetryBackoffSpec.errorFilter:Ljava/util/function/Predicate;
aload 3
invokeinterface java.util.function.Predicate.test:(Ljava/lang/Object;)Z
ifne 9
8: aload 3
invokestatic reactor.core.publisher.Mono.error:(Ljava/lang/Throwable;)Lreactor/core/publisher/Mono;
areturn
9: StackMap locals:
StackMap stack:
lload 4
aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxAttempts:J
lcmp
iflt 11
10: aload 0
getfield reactor.util.retry.RetryBackoffSpec.retryExhaustedGenerator:Ljava/util/function/BiFunction;
aload 0
aload 2
invokeinterface java.util.function.BiFunction.apply:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Throwable
invokestatic reactor.core.publisher.Mono.error:(Ljava/lang/Throwable;)Lreactor/core/publisher/Mono;
areturn
11: StackMap locals:
StackMap stack:
aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
ldc 2.0
lload 4
l2d
invokestatic java.lang.Math.pow:(DD)D
d2l
invokevirtual java.time.Duration.multipliedBy:(J)Ljava/time/Duration;
astore 6
start local 6 12: aload 6
aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
invokevirtual java.time.Duration.compareTo:(Ljava/time/Duration;)I
ifle 17
13: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
astore 6
14: goto 17
end local 6 15: StackMap locals:
StackMap stack: java.lang.ArithmeticException
pop
16: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
astore 6
start local 6 17: StackMap locals: java.time.Duration
StackMap stack:
aload 6
invokevirtual java.time.Duration.isZero:()Z
ifeq 21
18: aload 2
lload 4
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokestatic reactor.core.publisher.Mono.just:(Ljava/lang/Object;)Lreactor/core/publisher/Mono;
19: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
20: invokestatic reactor.util.retry.RetrySpec.applyHooks:(Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)Lreactor/core/publisher/Mono;
areturn
21: StackMap locals:
StackMap stack:
invokestatic java.util.concurrent.ThreadLocalRandom.current:()Ljava/util/concurrent/ThreadLocalRandom;
astore 7
start local 7 22: aload 6
ldc 100.0
aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
dmul
d2l
invokevirtual java.time.Duration.multipliedBy:(J)Ljava/time/Duration;
23: ldc 100
invokevirtual java.time.Duration.dividedBy:(J)Ljava/time/Duration;
24: invokevirtual java.time.Duration.toMillis:()J
25: lstore 8
start local 8 26: goto 29
end local 8 27: StackMap locals: reactor.util.retry.RetryBackoffSpec reactor.util.retry.Retry$RetrySignal reactor.util.retry.Retry$RetrySignal java.lang.Throwable long java.time.Duration java.util.concurrent.ThreadLocalRandom
StackMap stack: java.lang.ArithmeticException
pop
28: ldc 9.223372036854776E18
aload 0
getfield reactor.util.retry.RetryBackoffSpec.jitterFactor:D
dmul
invokestatic java.lang.Math.round:(D)J
lstore 8
start local 8 29: StackMap locals: long
StackMap stack:
aload 0
getfield reactor.util.retry.RetryBackoffSpec.minBackoff:Ljava/time/Duration;
aload 6
invokevirtual java.time.Duration.minus:(Ljava/time/Duration;)Ljava/time/Duration;
30: invokevirtual java.time.Duration.toMillis:()J
lload 8
lneg
31: invokestatic java.lang.Math.max:(JJ)J
lstore 10
start local 10 32: aload 0
getfield reactor.util.retry.RetryBackoffSpec.maxBackoff:Ljava/time/Duration;
aload 6
invokevirtual java.time.Duration.minus:(Ljava/time/Duration;)Ljava/time/Duration;
33: invokevirtual java.time.Duration.toMillis:()J
lload 8
34: invokestatic java.lang.Math.min:(JJ)J
lstore 12
start local 12 35: lload 12
lload 10
lcmp
ifne 40
36: lload 12
lconst_0
lcmp
ifne 38
lconst_0
lstore 14
start local 14 37: goto 41
end local 14 38: StackMap locals: long long
StackMap stack:
aload 7
lload 12
invokevirtual java.util.concurrent.ThreadLocalRandom.nextLong:(J)J
lstore 14
start local 14 39: goto 41
end local 14 40: StackMap locals:
StackMap stack:
aload 7
lload 10
lload 12
invokevirtual java.util.concurrent.ThreadLocalRandom.nextLong:(JJ)J
lstore 14
start local 14 41: StackMap locals: long
StackMap stack:
aload 6
lload 14
invokevirtual java.time.Duration.plusMillis:(J)Ljava/time/Duration;
astore 16
start local 16 42: aload 2
aload 16
43: aload 0
getfield reactor.util.retry.RetryBackoffSpec.backoffSchedulerSupplier:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast reactor.core.scheduler.Scheduler
44: invokestatic reactor.core.publisher.Mono.delay:(Ljava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/Mono;
45: aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPreRetry:Ljava/util/function/Consumer;
aload 0
getfield reactor.util.retry.RetryBackoffSpec.syncPostRetry:Ljava/util/function/Consumer;
aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPreRetry:Ljava/util/function/BiFunction;
aload 0
getfield reactor.util.retry.RetryBackoffSpec.asyncPostRetry:Ljava/util/function/BiFunction;
46: invokestatic reactor.util.retry.RetrySpec.applyHooks:(Lreactor/util/retry/Retry$RetrySignal;Lreactor/core/publisher/Mono;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/util/function/BiFunction;Ljava/util/function/BiFunction;)Lreactor/core/publisher/Mono;
areturn
end local 16 end local 14 end local 12 end local 10 end local 8 end local 7 end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 47 0 this Lreactor/util/retry/RetryBackoffSpec;
0 47 1 retryWhenState Lreactor/util/retry/Retry$RetrySignal;
1 47 2 copy Lreactor/util/retry/Retry$RetrySignal;
2 47 3 currentFailure Ljava/lang/Throwable;
5 47 4 iteration J
12 15 6 nextBackoff Ljava/time/Duration;
17 47 6 nextBackoff Ljava/time/Duration;
22 47 7 random Ljava/util/concurrent/ThreadLocalRandom;
26 27 8 jitterOffset J
29 47 8 jitterOffset J
32 47 10 lowBound J
35 47 12 highBound J
37 38 14 jitter J
39 40 14 jitter J
41 47 14 jitter J
42 47 16 effectiveBackoff Ljava/time/Duration;
Exception table:
from to target type
11 14 15 Class java.lang.ArithmeticException
22 26 27 Class java.lang.ArithmeticException
}
SourceFile: "RetryBackoffSpec.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract RetrySignal = reactor.util.retry.Retry$RetrySignal of reactor.util.retry.Retry