org.apache.brooklyn.util.collections.MutableSet.addAll()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(4.8k)|赞(0)|评价(0)|浏览(98)

本文整理了Java中org.apache.brooklyn.util.collections.MutableSet.addAll()方法的一些代码示例,展示了MutableSet.addAll()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MutableSet.addAll()方法的具体详情如下:
包路径:org.apache.brooklyn.util.collections.MutableSet
类名称:MutableSet
方法名:addAll

MutableSet.addAll介绍

暂无

代码示例

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

/** as {@link #addAll(Collection)} but fluent style and permitting null */
public MutableSet<V> putAll(Iterable<? extends V> setToAdd) {
  if (setToAdd!=null) addAll(setToAdd);
  return this;
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

public Builder<V> addAll(Iterable<? extends V> iterable) {
  if (iterable instanceof Collection) {
    result.addAll((Collection<? extends V>) iterable);
  } else {
    for (V v : iterable) {
      result.add(v);
    }
  }
  return this;
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

@Override
public Iterable<URL> getResources(String name) {
  MutableSet<URL> result = MutableSet.<URL>of();
  for (BrooklynClassLoadingContext target : primaries) {
    result.addAll(target.getResources(name));
  }
  for (BrooklynClassLoadingContext target : secondaries) {
    result.addAll(target.getResources(name));
  }
  return result;
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

@Override
protected Set<Object> merge(boolean unmodifiable, Iterable<?>... sets) {
  MutableSet<Object> result = MutableSet.of();
  for (Iterable<?> set: sets) result.addAll(set);
  if (unmodifiable) return result.asUnmodifiable();
  return result;
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

private void addReferencedObjects(DeltaCollector deltaCollector) {
  MutableSet<BrooklynObject> referencedObjects = MutableSet.of();
  
  // collect references
  for (Entity entity : deltaCollector.entities) {
    // FIXME How to let the policy/location tell us about changes? Don't do this every time!
    for (Location location : entity.getLocations()) {
      Collection<Location> findLocationsInHierarchy = TreeUtils.findLocationsInHierarchy(location);
      referencedObjects.addAll(findLocationsInHierarchy);
    }
    if (persistPoliciesEnabled) {
      referencedObjects.addAll(entity.policies());
    }
    if (persistEnrichersEnabled) {
      referencedObjects.addAll(entity.enrichers());
    }
    if (persistFeedsEnabled) {
      referencedObjects.addAll(((EntityInternal)entity).feeds().getFeeds());
    }
  }
  
  for (BrooklynObject instance : referencedObjects) {
    deltaCollector.addIfNotRemoved(instance);
  }
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

candidates.addAll(Iterables.filter(addrs.values(), Inet4Address.class));
candidates.addAll(addrs.values());
if (checkReachable) {
  for (InetAddress a: candidates) {

代码示例来源:origin: org.apache.brooklyn/brooklyn-rt-felix

@Test
public void testReadAManifest() throws Exception {
  Enumeration<URL> manifests = this.getClass().getClassLoader().getResources("META-INF/MANIFEST.MF");
  log.info("Bundles and exported packages:");
  MutableSet<String> allPackages = MutableSet.of();
  while (manifests.hasMoreElements()) {
    ManifestHelper mf = ManifestHelper.forManifestContents(Streams.readFullyStringAndClose(manifests.nextElement().openStream()));
    List<String> mfPackages = mf.getExportedPackages();
    log.info("  " + mf.getSymbolicNameVersion() + ": " + mfPackages);
    allPackages.addAll(mfPackages);
  }
  log.info("Total export package count: " + allPackages.size());
  Assert.assertTrue(allPackages.size() > 20, "did not find enough packages"); // probably much larger
  Assert.assertTrue(allPackages.contains(EmbeddedFelixFramework.class.getPackage().getName()));
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

@SuppressWarnings("deprecation")
protected Set<ConfigKey<?>> findKeys(Predicate<? super ConfigKey<?>> filter, KeyFindingMode mode) {
  MutableSet<ConfigKey<?>> result = MutableSet.of();
  if (mode==KeyFindingMode.DECLARED_OR_PRESENT) {
    result.addAll( Iterables.filter(getKeysAtContainer(getContainer()), filter) );
  }
  for (ConfigKey<?> k: Iterables.filter(ownConfig.keySet(), filter)) {
    if (result.contains(k)) continue;
    if (mode!=KeyFindingMode.PRESENT_NOT_RESOLVED) {
      ConfigKey<?> k2 = getKeyAtContainer(getContainer(), k);
      if (k2!=null) k = k2;
    }
    result.add(k);
  }
  // due to set semantics local should be added first, it prevents equal items from parent from being added on top
  if (getParent()!=null) {
    // now take from runtime parents, but filtered
    Set<ConfigKey<?>> inherited;
    switch (mode) {
    case DECLARED_OR_PRESENT:  inherited = getParentInternal().config().getInternalConfigMap().findKeysDeclared(filter); break;
    case PRESENT_AND_RESOLVED: inherited = getParentInternal().config().getInternalConfigMap().findKeysPresent(filter); break;
    case PRESENT_NOT_RESOLVED: inherited = getParentInternal().config().getInternalConfigMap().findKeys(filter); break;
    default:
      throw new IllegalStateException("Unsupported key finding mode: "+mode);
    }
    // TODO due to recursive nature we call this N times for the Nth level ancestor 
    result.addAll( filterOutRuntimeNotReinherited(inherited) );
  }
  return result;
}

相关文章