com.google.common.collect.Multiset.forEach()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(4.2k)|赞(0)|评价(0)|浏览(139)

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

Multiset.forEach介绍

[英]Elements that occur multiple times in the multiset will be passed to the Consumercorrespondingly many times, though not necessarily sequentially.
[中]在multiset中多次出现的元素将相应地多次传递给使用者,尽管不一定是按顺序传递。

代码示例

代码示例来源:origin: javers/javers

  1. @Override
  2. public JsonElement toJson(Multiset sourceValue, Type typeOfT, JsonSerializationContext context) {
  3. JsonArray jsonArray = new JsonArray();
  4. sourceValue.forEach(e -> {
  5. jsonArray.add(context.serialize(e));
  6. });
  7. return jsonArray;
  8. }

代码示例来源:origin: GoogleCloudPlatform/google-cloud-intellij

  1. @Override
  2. public void disconnect() {
  3. synchronized (createdDeployments) {
  4. // Kills any executing deployment actions.
  5. createdDeployments.values().forEach(CancellableRunnable::cancel);
  6. createdDeployments
  7. .keys()
  8. .forEach(
  9. project ->
  10. ProjectManager.getInstance()
  11. .removeProjectManagerListener(project, projectClosingListener));
  12. createdDeployments.clear();
  13. }
  14. }
  15. }

代码示例来源:origin: batfish/batfish

  1. @Override
  2. public AnswerElement answer() {
  3. DetectLoopsQuestion question = (DetectLoopsQuestion) _question;
  4. Set<Flow> flows = _batfish.bddLoopDetection();
  5. /*
  6. * There can be many flows exercising the same loop, so let's pick one per dstIp.
  7. */
  8. Multimap<Ip, Flow> flowsPerDst =
  9. flows.stream()
  10. .collect(
  11. Multimaps.toMultimap(Flow::getDstIp, Functions.identity(), HashMultimap::create));
  12. flows =
  13. flowsPerDst.asMap().values().stream()
  14. .flatMap(flowsWithSameDst -> flowsWithSameDst.stream().limit(1))
  15. .collect(Collectors.toSet());
  16. if (_batfish.debugFlagEnabled("oldtraceroute")) {
  17. FlowHistory flowHistory = _batfish.flowHistory(flows, false);
  18. Multiset<Row> rows = flowHistoryToRows(flowHistory);
  19. TableAnswerElement table = new TableAnswerElement(createMetadata(false));
  20. table.postProcessAnswer(_question, rows);
  21. return table;
  22. } else {
  23. SortedMap<Flow, List<Trace>> flowTraces = _batfish.buildFlows(flows, false);
  24. TableAnswerElement tableAnswer = new TableAnswerElement(TracerouteAnswerer.metadata(false));
  25. TracerouteAnswerer.flowTracesToRows(flowTraces, question.getMaxTraces())
  26. .forEach(tableAnswer::addRow);
  27. return tableAnswer;
  28. }
  29. }

代码示例来源:origin: batfish/batfish

  1. @Override
  2. public AnswerElement answer() {
  3. SpecifiersReachabilityQuestion question = (SpecifiersReachabilityQuestion) _question;
  4. AnswerElement answer = _batfish.standard(question.getReachabilityParameters());
  5. if (answer instanceof TraceWrapperAsAnswerElement) {
  6. TableAnswerElement tableAnswer = new TableAnswerElement(TracerouteAnswerer.metadata(false));
  7. TracerouteAnswerer.flowTracesToRows(
  8. ((TraceWrapperAsAnswerElement) answer).getFlowTraces(), question.getMaxTraces())
  9. .forEach(tableAnswer::addRow);
  10. return tableAnswer;
  11. } else if (answer instanceof FlowHistory) {
  12. TableAnswerElement tableAnswer =
  13. new TableAnswerElement(TracerouteAnswerer.createMetadata(false));
  14. TracerouteAnswerer.flowHistoryToRows((FlowHistory) answer, false)
  15. .forEach(tableAnswer::addRow);
  16. return tableAnswer;
  17. } else {
  18. return answer;
  19. }
  20. }
  21. }

代码示例来源:origin: KleeGroup/vertigo

  1. /**
  2. * Add all the classes with a package prefix in the scope.
  3. * @param packageName the root package
  4. * @return the selector
  5. */
  6. public Selector from(final String packageName) {
  7. Assertion.checkArgNotEmpty(packageName);
  8. checkScope();
  9. // ---
  10. new Reflections(packageName,
  11. new TypeElementsScanner().includeAnnotations(false).includeFields(false).includeMethods(false))
  12. .getStore()
  13. .get(TypeElementsScanner.class.getSimpleName())
  14. .keys()
  15. .forEach(className -> from(ClassUtil.classForName(className)));
  16. return this;
  17. }

代码示例来源:origin: batfish/batfish

  1. @Override
  2. public AnswerElement answer() {
  3. MultipathConsistencyParameters parameters = parameters();
  4. Set<Flow> flows = _batfish.bddMultipathConsistency(parameters);
  5. if (_batfish.debugFlagEnabled("oldtraceroute")) {
  6. FlowHistory flowHistory = _batfish.flowHistory(flows, false);
  7. Multiset<Row> rows = flowHistoryToRows(flowHistory);
  8. TableAnswerElement table = new TableAnswerElement(createMetadata(false));
  9. table.postProcessAnswer(_question, rows);
  10. return table;
  11. } else {
  12. SortedMap<Flow, List<Trace>> flowTraces = _batfish.buildFlows(flows, false);
  13. TableAnswerElement tableAnswer = new TableAnswerElement(TracerouteAnswerer.metadata(false));
  14. TracerouteAnswerer.flowTracesToRows(flowTraces, parameters.getMaxTraces())
  15. .forEach(tableAnswer::addRow);
  16. return tableAnswer;
  17. }
  18. }

相关文章