* Register device synchronize listeners
* @param deviceSynchronizeListener are notified if device is synchronized or not
*/
- void registerDeviceSynchronizeListeners(final DeviceSynchronizeListener deviceSynchronizeListener);
+ void addDeviceSynchronizeListener(final DeviceSynchronizeListener deviceSynchronizeListener);
/**
* Notify all registered listeners about synchronized status
* Register device valid listeners
* @param deviceValidListener are notified if device is valid or not
*/
- void registerDeviceValidListeners(final DeviceValidListener deviceValidListener);
+ void addDeviceValidListener(final DeviceValidListener deviceValidListener);
/**
* Notify all registered listeners about valid status
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import io.netty.util.TimerTask;
-import java.util.ArrayList;
import java.util.Collections;
+import java.util.HashSet;
import java.util.Iterator;
-import java.util.List;
+import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.ExecutionException;
private final int barrierCountLimit;
private ExtensionConverterProvider extensionConverterProvider;
private ScheduledThreadPoolExecutor spyPool;
- private List<DeviceSynchronizeListener> deviceSynchronizedListeners;
- private List<DeviceValidListener> deviceValidListeners;
+ private Set<DeviceSynchronizeListener> deviceSynchronizedListeners;
+ private Set<DeviceValidListener> deviceValidListeners;
private final LifecycleConductor conductor;
this.conductor = lifecycleConductor;
spyPool = new ScheduledThreadPoolExecutor(1);
- this.deviceSynchronizedListeners = new ArrayList<>();
- this.deviceValidListeners = new ArrayList<>();
+ this.deviceSynchronizedListeners = new HashSet<>();
+ this.deviceValidListeners = new HashSet<>();
}
connectionContext.setOutboundQueueHandleRegistration(outboundQueueHandlerRegistration);
final DeviceState deviceState = new DeviceStateImpl(deviceInfo);
- this.registerDeviceSynchronizeListeners(deviceState);
- this.registerDeviceValidListeners(deviceState);
+ this.addDeviceSynchronizeListener(deviceState);
+ this.addDeviceValidListener(deviceState);
final DeviceContext deviceContext = new DeviceContextImpl(connectionContext,
deviceState,
}
@Override
- public void registerDeviceSynchronizeListeners(final DeviceSynchronizeListener deviceSynchronizeListener) {
+ public void addDeviceSynchronizeListener(final DeviceSynchronizeListener deviceSynchronizeListener) {
this.deviceSynchronizedListeners.add(deviceSynchronizeListener);
}
}
@Override
- public void registerDeviceValidListeners(final DeviceValidListener deviceValidListener) {
+ public void addDeviceValidListener(final DeviceValidListener deviceValidListener) {
this.deviceValidListeners.add(deviceValidListener);
}