Skip to content
Snippets Groups Projects

Resolve "(UBI) Refactor Policy"

Merged Konstantinos Poulakakis requested to merge feat/112-ubi-refactor-policy into develop
All threads resolved!
1 file
+ 3
5
Compare changes
  • Side-by-side
  • Inline
@@ -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