Преглед изворни кода

DefaultAsyncEvent.async 不能正确处理 Flux

Winston пре 3 година
родитељ
комит
f50dd08430

+ 1 - 1
jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/LocalDeviceInstanceService.java

@@ -542,7 +542,7 @@ public class LocalDeviceInstanceService extends GenericReactiveCrudService<Devic
     @EventListener
     public void deletedHandle(EntityDeletedEvent<DeviceInstanceEntity> event) {
         event.async(
-            this.deletedHandle(Flux.fromIterable(event.getEntity()))
+            this.deletedHandle(Flux.fromIterable(event.getEntity())).then()
         );
     }
 }