Skip to content
This repository was archived by the owner on Mar 3, 2026. It is now read-only.

Commit 3b552da

Browse files
feffijknack
authored andcommitted
fixed minor code issues (jooby-project#1171)
(cherry picked from commit aac2fdf)
1 parent 8c03f35 commit 3b552da

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

modules/jooby-rxjava/src/main/java/org/jooby/rx/ExecSchedulerHook.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -213,7 +213,7 @@
213213

214214
class ExecSchedulerHook extends RxJavaSchedulersHook {
215215

216-
private Throwing.Function<String, Scheduler> schedulers;
216+
private final Throwing.Function<String, Scheduler> schedulers;
217217

218218
public ExecSchedulerHook(final Map<String, Executor> executors) {
219219
// we don't want eager initialization of Schedulers

modules/jooby-rxjava/src/main/java/org/jooby/rx/Rx.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -357,7 +357,7 @@ static class DeferredSubscriber extends Subscriber<Object> {
357357

358358
private Deferred deferred;
359359

360-
private AtomicBoolean done = new AtomicBoolean(false);
360+
private final AtomicBoolean done = new AtomicBoolean(false);
361361

362362
public DeferredSubscriber(final Deferred deferred) {
363363
this.deferred = deferred;
@@ -366,7 +366,7 @@ public DeferredSubscriber(final Deferred deferred) {
366366
@Override
367367
public void onCompleted() {
368368
if (done.compareAndSet(false, true)) {
369-
deferred.resolve((Object) null);
369+
deferred.resolve(null);
370370
}
371371
deferred = null;
372372
}

0 commit comments

Comments
 (0)