Update AsyncTdEasy.java
This commit is contained in:
parent
a10158ae92
commit
4fc610c1ac
@ -58,7 +58,7 @@ public class AsyncTdEasy {
|
|||||||
|
|
||||||
private final Logger logger;
|
private final Logger logger;
|
||||||
|
|
||||||
private static final Scheduler scheduler = Schedulers.newSingle("AsyncTdEasy", true);
|
private static final Scheduler scheduler = Schedulers.parallel();
|
||||||
private final Many<AuthorizationState> authState = Sinks.many().replay().latest();
|
private final Many<AuthorizationState> authState = Sinks.many().replay().latest();
|
||||||
private final Many<Boolean> requestedDefinitiveExit = Sinks.many().replay().latestOrDefault(false);
|
private final Many<Boolean> requestedDefinitiveExit = Sinks.many().replay().latestOrDefault(false);
|
||||||
private final Many<TdEasySettings> settings = Sinks.many().replay().latest();
|
private final Many<TdEasySettings> settings = Sinks.many().replay().latest();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user