...
Code Block | ||
---|---|---|
| ||
// In CPS core Stream<DataNode> queryDataNodesAsStream(String dataspaceName, String anchorName, String cpsPath, FetchDescendantsOption fetchDescendantsOption) { final var anchor = return fragmentRepository.streamByAnchorAndCpsPath(getAnchor(dataspaceName, anchorName); return fragmentRepository.streamByAnchorAndCpsPath(anchor, cpsPath) .map(fragment -> fetchDescendants(fragment, fetchDescendantsOption)) .map(fragment -> toDataNode(fragment)); } // In NCMP private YangModelCmHandle getAnyReadyCmHandleByModuleSetTag(final String moduleSetTag) { return cmHandleQueries.queryNcmpRegistryByCpsPath("/dmi-registry/cm-handles[@module-set-tag='" + moduleSetTag + "']", DIRECT_CHILDREN_ONLY) .map(YangDataConverter::convertCmHandleToYangModel) .filter(cmHandle -> cmHandle.getCompositeState().getCmHandleState() == CmHandleState.READY) .findFirst() .orElse(null); } |
...