Skip to content

Commit 23f9d82

Browse files
committed
Rename VertxFutureWrapper to VertxTimerScheduledFuture
This is an early design refactoring leftover.
1 parent be74ffc commit 23f9d82

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

extensions/vertx/runtime/src/main/java/io/quarkus/vertx/core/runtime/VertxTimerAwareScheduledExecutorService.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -32,16 +32,16 @@ protected ScheduledExecutorService delegate() {
3232
return delegate;
3333
}
3434

35-
// ------------------ ScheduledFuture over Vert.x Future ------------------ //
35+
// ------------------ ScheduledFuture for timers ------------------ //
3636

37-
private static final class VertxFutureWrapper<T> implements ScheduledFuture<T> {
37+
private static final class VertxTimerScheduledFuture<T> implements ScheduledFuture<T> {
3838

3939
final Vertx vertx;
4040
final long timerId;
4141
volatile boolean cancelled;
4242

4343
// Minimal wrapper class with just what is need to support cancellation
44-
VertxFutureWrapper(Vertx vertx, long timerId) {
44+
VertxTimerScheduledFuture(Vertx vertx, long timerId) {
4545
this.vertx = vertx;
4646
this.timerId = timerId;
4747
}
@@ -97,7 +97,7 @@ public void handle(Long tick) {
9797
command.run();
9898
}
9999
});
100-
return new VertxFutureWrapper<>(vertx, timerId);
100+
return new VertxTimerScheduledFuture<>(vertx, timerId);
101101
}
102102
return delegate.schedule(command, delay, unit);
103103
}
@@ -113,7 +113,7 @@ public void handle(Long tick) {
113113
command.run();
114114
}
115115
});
116-
return new VertxFutureWrapper<Void>(vertx, timerId);
116+
return new VertxTimerScheduledFuture<Void>(vertx, timerId);
117117
}
118118
return delegate.scheduleAtFixedRate(command, initialDelay, period, unit);
119119
}

0 commit comments

Comments
 (0)