Skip to content

Commit f1e02ce

Browse files
committed
Expose DataItems via SubscriptionModel::getDataItems
1 parent 580bc5b commit f1e02ce

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

opc-ua-sdk/sdk-server/src/main/java/org/eclipse/milo/opcua/sdk/server/util/SubscriptionModel.java

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,15 @@ public void onMonitoringModeChanged(List<MonitoredItem> items) {
114114
executionQueue.submit(this::reschedule);
115115
}
116116

117+
/**
118+
* Get a copy of the {@link DataItem}s in this {@link SubscriptionModel}.
119+
*
120+
* @return a copy of the {@link DataItem}s in this {@link SubscriptionModel}.
121+
*/
122+
public List<DataItem> getDataItems() {
123+
return List.copyOf(itemSet);
124+
}
125+
117126
private void reschedule() {
118127
Map<Double, List<DataItem>> bySamplingInterval =
119128
itemSet.stream()
@@ -128,7 +137,7 @@ private void reschedule() {
128137

129138
return new ScheduledUpdate(samplingInterval, items);
130139
})
131-
.collect(Collectors.toList());
140+
.toList();
132141

133142
schedule.forEach(ScheduledUpdate::cancel);
134143
schedule.clear();
@@ -165,7 +174,7 @@ public void run() {
165174
List<PendingRead> pending =
166175
sessionItems.stream()
167176
.map(item -> new PendingRead(item.getReadValueId()))
168-
.collect(Collectors.toList());
177+
.toList();
169178

170179
List<ReadValueId> ids =
171180
pending.stream().map(PendingRead::getInput).collect(Collectors.toList());

0 commit comments

Comments
 (0)