+ private void registerDelayedListeners(DelayedListenerRegistration reg) {
+ if(!reg.isClosed()) {
+ final Entry<DataChangeListenerRegistration<AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>>>,
+ Optional<DataTreeCandidate>> res = createDelegate(reg.getRegisterChangeListener());
+ reg.setDelegate(res.getKey());
+ getShard().getDataStore().notifyOfInitialData(res.getKey(), res.getValue());
+ }
+ }
+