mirror of
https://github.com/xpipe-io/xpipe.git
synced 2026-09-29 03:45:43 +00:00
Rework hierarchy for network ports
This commit is contained in:
@@ -745,6 +745,7 @@ public abstract class DataStorage {
|
||||
}
|
||||
|
||||
var oldChildren = getStoreChildren(e);
|
||||
var oldDeepChildren = getDeepStoreChildren(e);
|
||||
var toRemove = oldChildren.stream()
|
||||
.filter(oc -> {
|
||||
var oid = getFixedChildId(oc);
|
||||
@@ -767,7 +768,7 @@ public abstract class DataStorage {
|
||||
return false;
|
||||
}
|
||||
|
||||
return oldChildren.stream()
|
||||
return oldDeepChildren.stream()
|
||||
.filter(oc -> oc.getStore() instanceof FixedChildStore)
|
||||
.filter(oc -> getFixedChildId(oc).isPresent())
|
||||
.noneMatch(oc -> {
|
||||
@@ -775,7 +776,7 @@ public abstract class DataStorage {
|
||||
});
|
||||
})
|
||||
.toList();
|
||||
var toUpdate = new ArrayList<>(oldChildren.stream()
|
||||
var toUpdate = new ArrayList<>(oldDeepChildren.stream()
|
||||
.map(oc -> {
|
||||
var oid = getFixedChildId(oc);
|
||||
if (oid.isEmpty()) {
|
||||
|
||||
@@ -661,7 +661,7 @@ public class DataStoreEntry extends DataStorageElement {
|
||||
notifyUpdate(false, true);
|
||||
}
|
||||
|
||||
void setStoreInternal(DataStore store, boolean updateTime) {
|
||||
public void setStoreInternal(DataStore store, boolean updateTime) {
|
||||
var changed = !Objects.equals(getStore(), store);
|
||||
if (!changed) {
|
||||
return;
|
||||
|
||||
Reference in New Issue
Block a user