|
1 | 1 | /*
|
2 |
| - * Copyright 2002-2024 the original author or authors. |
| 2 | + * Copyright 2002-2025 the original author or authors. |
3 | 3 | *
|
4 | 4 | * Licensed under the Apache License, Version 2.0 (the "License");
|
5 | 5 | * you may not use this file except in compliance with the License.
|
@@ -205,9 +205,9 @@ static final class SubscribingRunnable implements SchedulingAwareRunnable {
|
205 | 205 | final Supplier<ScheduledTaskObservationContext> contextSupplier;
|
206 | 206 |
|
207 | 207 | SubscribingRunnable(Publisher<?> publisher, boolean shouldBlock,
|
208 |
| - @Nullable String qualifier, List<Runnable> subscriptionTrackerRegistry, |
209 |
| - String displayName, Supplier<ObservationRegistry> observationRegistrySupplier, |
210 |
| - Supplier<ScheduledTaskObservationContext> contextSupplier) { |
| 208 | + @Nullable String qualifier, List<Runnable> subscriptionTrackerRegistry, |
| 209 | + String displayName, Supplier<ObservationRegistry> observationRegistrySupplier, |
| 210 | + Supplier<ScheduledTaskObservationContext> contextSupplier) { |
211 | 211 |
|
212 | 212 | this.publisher = publisher;
|
213 | 213 | this.shouldBlock = shouldBlock;
|
@@ -236,7 +236,7 @@ public void run() {
|
236 | 236 | latch.await();
|
237 | 237 | }
|
238 | 238 | catch (InterruptedException ex) {
|
239 |
| - throw new RuntimeException(ex); |
| 239 | + Thread.currentThread().interrupt(); |
240 | 240 | }
|
241 | 241 | }
|
242 | 242 | else {
|
|
0 commit comments