Update pom.xml and AsyncTdDirectImpl.java
This commit is contained in:
parent
675234cd51
commit
7f8300fec5
4
pom.xml
4
pom.xml
|
@ -71,12 +71,12 @@
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>io.projectreactor</groupId>
|
<groupId>io.projectreactor</groupId>
|
||||||
<artifactId>reactor-core</artifactId>
|
<artifactId>reactor-core</artifactId>
|
||||||
<version>3.3.10.RELEASE</version>
|
<version>3.4.0</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>io.projectreactor</groupId>
|
<groupId>io.projectreactor</groupId>
|
||||||
<artifactId>reactor-tools</artifactId>
|
<artifactId>reactor-tools</artifactId>
|
||||||
<version>3.3.10.RELEASE</version>
|
<version>3.4.0</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.slf4j</groupId>
|
<groupId>org.slf4j</groupId>
|
||||||
|
|
|
@ -15,7 +15,6 @@ import java.time.Duration;
|
||||||
import java.util.concurrent.atomic.AtomicReference;
|
import java.util.concurrent.atomic.AtomicReference;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import reactor.core.publisher.EmitterProcessor;
|
|
||||||
import reactor.core.publisher.Flux;
|
import reactor.core.publisher.Flux;
|
||||||
import reactor.core.publisher.Mono;
|
import reactor.core.publisher.Mono;
|
||||||
import reactor.core.scheduler.Scheduler;
|
import reactor.core.scheduler.Scheduler;
|
||||||
|
@ -29,6 +28,7 @@ public class AsyncTdDirectImpl implements AsyncTdDirect {
|
||||||
private final Scheduler tdScheduler = Schedulers.newSingle("TdMain");
|
private final Scheduler tdScheduler = Schedulers.newSingle("TdMain");
|
||||||
private final Scheduler tdPollScheduler = Schedulers.newSingle("TdPoll");
|
private final Scheduler tdPollScheduler = Schedulers.newSingle("TdPoll");
|
||||||
private final Scheduler tdResponsesScheduler = Schedulers.newSingle("TdResponse");
|
private final Scheduler tdResponsesScheduler = Schedulers.newSingle("TdResponse");
|
||||||
|
private final Scheduler tdExecScheduler = Schedulers.newSingle("TdExec");
|
||||||
private final Scheduler tdResponsesOutputScheduler = Schedulers.boundedElastic();
|
private final Scheduler tdResponsesOutputScheduler = Schedulers.boundedElastic();
|
||||||
|
|
||||||
private Flux<AsyncResult<TdResult<Update>>> updatesProcessor;
|
private Flux<AsyncResult<TdResult<Update>>> updatesProcessor;
|
||||||
|
@ -44,7 +44,7 @@ public class AsyncTdDirectImpl implements AsyncTdDirect {
|
||||||
return Mono
|
return Mono
|
||||||
.fromCallable(() -> TdResult.<T>of(this.td.get().execute(request)))
|
.fromCallable(() -> TdResult.<T>of(this.td.get().execute(request)))
|
||||||
.subscribeOn(tdResponsesScheduler)
|
.subscribeOn(tdResponsesScheduler)
|
||||||
.publishOn(Schedulers.single());
|
.publishOn(tdExecScheduler);
|
||||||
} else {
|
} else {
|
||||||
return Mono.<TdResult<T>>create(sink -> {
|
return Mono.<TdResult<T>>create(sink -> {
|
||||||
try {
|
try {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user