Skip to content

Commit 2a2e76d

Browse files
author
Daniel Türk
committed
bugfix: call addConsumer by addConsumers instead of adding all to list
1 parent 55add5e commit 2a2e76d

File tree

1 file changed

+11
-1
lines changed

1 file changed

+11
-1
lines changed

api/src/main/java/net/wbz/selectrix4java/api/bus/BusDataDispatcher.java

+11-1
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,9 @@ public void registerConsumer(BusDataConsumer consumer) {
6969
}
7070

7171
public void registerConsumers(List<BusDataConsumer> consumers) {
72-
this.consumers.addAll(consumers);
72+
for (BusDataConsumer consumer : consumers) {
73+
registerConsumer(consumer);
74+
}
7375
}
7476

7577
public void unregisterConsumer(BusDataConsumer consumer) {
@@ -80,6 +82,14 @@ public void unregisterConsumers(List<BusDataConsumer> consumers) {
8082
this.consumers.removeAll(consumers);
8183
}
8284

85+
/**
86+
* Perform an update by calling all registered consumers with the current data of the bus addresses.
87+
* Each consumer will be called for an value change.
88+
*/
89+
public void requestConsumersDataUpdate() {
90+
91+
}
92+
8393
@Override
8494
public void received(int busNr, byte[] data) {
8595
boolean firstTimeDataReceived = !busData.containsKey(busNr);

0 commit comments

Comments
 (0)