Loading src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java +3 −5 Original line number Diff line number Diff line Loading @@ -383,15 +383,13 @@ public class PolicyServiceImpl implements PolicyService { List<Multi<AlarmResponse>> alarmResponseStreamList = new ArrayList<>(); for (Uni<String> alarmId : alarmIds) { alarmResponseStreamList.add( alarmId .onItem() .transformToMulti( id -> setPolicyMonitoringDevice(policyRuleDevice, id))); alarmId.onItem().transformToMulti(id -> setPolicyMonitoringDevice(policyRuleDevice, id))); } return alarmResponseStreamList; } private Multi<AlarmResponse> setPolicyMonitoringDevice(PolicyRuleDevice policyRuleDevice, String id){ private Multi<AlarmResponse> setPolicyMonitoringDevice( PolicyRuleDevice policyRuleDevice, String id) { alarmPolicyRuleDeviceMap.put(id, policyRuleDevice); // TODO: Create infinite subscription Loading Loading
src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java +3 −5 Original line number Diff line number Diff line Loading @@ -383,15 +383,13 @@ public class PolicyServiceImpl implements PolicyService { List<Multi<AlarmResponse>> alarmResponseStreamList = new ArrayList<>(); for (Uni<String> alarmId : alarmIds) { alarmResponseStreamList.add( alarmId .onItem() .transformToMulti( id -> setPolicyMonitoringDevice(policyRuleDevice, id))); alarmId.onItem().transformToMulti(id -> setPolicyMonitoringDevice(policyRuleDevice, id))); } return alarmResponseStreamList; } private Multi<AlarmResponse> setPolicyMonitoringDevice(PolicyRuleDevice policyRuleDevice, String id){ private Multi<AlarmResponse> setPolicyMonitoringDevice( PolicyRuleDevice policyRuleDevice, String id) { alarmPolicyRuleDeviceMap.put(id, policyRuleDevice); // TODO: Create infinite subscription Loading