|
@@ -151,10 +151,11 @@ class TcpServerDeviceGateway implements DeviceGateway, MonitorSupportDeviceGatew
|
|
return client
|
|
return client
|
|
.subscribe()
|
|
.subscribe()
|
|
.filter(tcp -> started.get())
|
|
.filter(tcp -> started.get())
|
|
- .doOnCancel(client::shutdown)
|
|
|
|
|
|
+ .publishOn(Schedulers.parallel())
|
|
.flatMap(this::handleTcpMessage)
|
|
.flatMap(this::handleTcpMessage)
|
|
.onErrorContinue((err, ignore) -> log.error(err.getMessage(), err))
|
|
.onErrorContinue((err, ignore) -> log.error(err.getMessage(), err))
|
|
- .then();
|
|
|
|
|
|
+ .then()
|
|
|
|
+ .doOnCancel(client::shutdown);
|
|
}
|
|
}
|
|
|
|
|
|
Mono<Void> handleTcpMessage(TcpMessage message) {
|
|
Mono<Void> handleTcpMessage(TcpMessage message) {
|