|
|
|
@ -1,5 +1,5 @@ |
|
|
|
/* |
|
|
|
/* |
|
|
|
* Copyright 2002-2024 the original author or authors. |
|
|
|
* Copyright 2002-2025 the original author or authors. |
|
|
|
* |
|
|
|
* |
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
|
|
* you may not use this file except in compliance with the License. |
|
|
|
* you may not use this file except in compliance with the License. |
|
|
|
@ -205,9 +205,9 @@ abstract class ScheduledAnnotationReactiveSupport { |
|
|
|
final Supplier<ScheduledTaskObservationContext> contextSupplier; |
|
|
|
final Supplier<ScheduledTaskObservationContext> contextSupplier; |
|
|
|
|
|
|
|
|
|
|
|
SubscribingRunnable(Publisher<?> publisher, boolean shouldBlock, |
|
|
|
SubscribingRunnable(Publisher<?> publisher, boolean shouldBlock, |
|
|
|
@Nullable String qualifier, List<Runnable> subscriptionTrackerRegistry, |
|
|
|
@Nullable String qualifier, List<Runnable> subscriptionTrackerRegistry, |
|
|
|
String displayName, Supplier<ObservationRegistry> observationRegistrySupplier, |
|
|
|
String displayName, Supplier<ObservationRegistry> observationRegistrySupplier, |
|
|
|
Supplier<ScheduledTaskObservationContext> contextSupplier) { |
|
|
|
Supplier<ScheduledTaskObservationContext> contextSupplier) { |
|
|
|
|
|
|
|
|
|
|
|
this.publisher = publisher; |
|
|
|
this.publisher = publisher; |
|
|
|
this.shouldBlock = shouldBlock; |
|
|
|
this.shouldBlock = shouldBlock; |
|
|
|
@ -236,7 +236,7 @@ abstract class ScheduledAnnotationReactiveSupport { |
|
|
|
latch.await(); |
|
|
|
latch.await(); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (InterruptedException ex) { |
|
|
|
catch (InterruptedException ex) { |
|
|
|
throw new RuntimeException(ex); |
|
|
|
Thread.currentThread().interrupt(); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
else { |
|
|
|
else { |
|
|
|
|