|
|
@@ -95,6 +95,7 @@ public class DeviceDirectiveController implements
|
|
|
List<DeviceOperator> t2 = tp2.getT2();
|
|
|
DeviceMessage message = tp2.getT1();
|
|
|
return Flux.fromStream(t2.stream())
|
|
|
+ .doOnNext(operator -> ((CommonDeviceMessage)message).setDeviceId(operator.getDeviceId()))
|
|
|
.flatMap(operator -> Mono.just(operator.messageSender()))
|
|
|
.flatMap(sender->{
|
|
|
//同步进行
|