We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d82f1be commit 2bf53a9Copy full SHA for 2bf53a9
src/main/java/rx/internal/schedulers/SleepingAction.java
@@ -34,15 +34,14 @@ public void call() {
34
if (innerScheduler.isUnsubscribed()) {
35
return;
36
}
37
- if (execTime > innerScheduler.now()) {
38
- long delay = execTime - innerScheduler.now();
39
- if (delay > 0) {
40
- try {
41
- Thread.sleep(delay);
42
- } catch (InterruptedException e) {
43
- Thread.currentThread().interrupt();
44
- throw new RuntimeException(e);
45
- }
+
+ long delay = execTime - innerScheduler.now();
+ if (delay > 0) {
+ try {
+ Thread.sleep(delay);
+ } catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
+ throw new RuntimeException(e);
46
47
48
0 commit comments