java.util.LinkedList.stream()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(7.4k)|赞(0)|评价(0)|浏览(366)

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

LinkedList.stream介绍

暂无

代码示例

代码示例来源：origin: speedment/speedment

  1. @Override
  2. public Stream<Action<?, ?>> stream() {
  3.   return list.stream();
  4. }

代码示例来源：origin: jersey/jersey

  1. @Override
  2. public List<String> getMatchedURIs(final boolean decode) {
  3.   final List<String> result;
  4.   if (decode) {
  5.     result = paths.stream().map(PATH_DECODER).collect(Collectors.toList());
  6.   } else {
  7.     result = paths;
  8.   }
  9.   return Collections.unmodifiableList(result);
  10. }

代码示例来源：origin: jersey/jersey

  1. @Override
  2. public List<String> getMatchedURIs(final boolean decode) {
  3.   final List<String> result;
  4.   if (decode) {
  5.     result = paths.stream().map(PATH_DECODER).collect(Collectors.toList());
  6.   } else {
  7.     result = paths;
  8.   }
  9.   return Collections.unmodifiableList(result);
  10. }

代码示例来源：origin: pentaho/pentaho-kettle

  1. private ImmutableList<Operation> filterOperations( Predicate<Operation> filter ) {
  2.  ImmutableList.Builder<Operation> builder = ImmutableList.builder();
  3.  operations.stream().filter( filter ).forEach( builder::add );
  4.  return builder.build();
  5. }

代码示例来源：origin: ethereum/ethereumj

  1. private int calcGasPricesSize() {
  2.   return blockGasPrices.stream().map(Array::getLength).mapToInt(Integer::intValue).sum();
  3. }

代码示例来源：origin: jooby-project/jooby

  1. private String summary() {
  2.  return summary.stream().collect(Collectors.joining());
  3. }

代码示例来源：origin: twosigma/beakerx

  1. private int lengthOfCoordinates(LinkedList<String> parts, String last) {
  2.  return parts.stream().mapToInt(x -> x.length() + 1).sum() + last.length();
  3. }

代码示例来源：origin: org.apache.ant/ant

  1. /**
  2.  * Returns all named entries in the same order their contents
  3.  * appear within the archive.
  4.  *
  5.  * @param name name of the entry.
  6.  * @return the Iterable&lt;ZipEntry&gt; corresponding to the
  7.  * given name
  8.  * @since 1.9.2
  9.  */
  10. public Iterable<ZipEntry> getEntriesInPhysicalOrder(final String name) {
  11.   if (nameMap.containsKey(name)) {
  12.     return nameMap.get(name).stream().sorted(OFFSET_COMPARATOR)
  13.       .collect(Collectors.toList());
  14.   }
  15.   return Collections.emptyList();
  16. }

代码示例来源：origin: atomix/atomix

  1. @Override
  2. public QueueStatus queueStatus() {
  3.  int permits = waiterQueue.stream().map(w -> w.acquirePermits).reduce(0, Integer::sum);
  4.  return new QueueStatus(waiterQueue.size(), permits);
  5. }

代码示例来源：origin: oracle/helidon

  1. <T> Optional<Mapper<T>> findMapper(GenericType<T> type, Config.Key key) {
  2.   return providers.stream()
  3.       .map(provider -> provider.apply(type))
  4.       .filter(Optional::isPresent)
  5.       .map(Optional::get)
  6.       .findFirst()
  7.       .map(mapper -> castMapper(type, mapper, key))
  8.       .map(Mapper::create);
  9. }

代码示例来源：origin: RichardWarburton/java-8-lambdas-exercises

  1. @GenerateMicroBenchmark
  2. public int serialLinkedList() {
  3.   return linkedList.stream().mapToInt(i -> i).sum();
  4. }

代码示例来源：origin: pentaho/pentaho-kettle

  1. public org.pentaho.di.engine.model.Hop createHop( Operation from, Operation to, String type ) {
  2.  Preconditions.checkArgument( operations.contains( from ), "!operations.contains(from)" );
  3.  Preconditions.checkArgument( operations.contains( to ), "!operations.contains(to)" );
  4.  Preconditions.checkArgument( from != to, "from == to" );
  5.  org.pentaho.di.engine.model.Hop hop = new org.pentaho.di.engine.model.Hop( from, to, type );
  6.  Preconditions.checkState( hops.stream().noneMatch( it -> it.getFrom() == from && it.getTo() == to ),
  7.   "Hop from %s to %s already exists", from, to );
  8.  hops.add( hop );
  9.  return hop;
  10. }

代码示例来源：origin: jooby-project/jooby

  1. private Optional<String> prefixPath(@Nullable String tail) {
  2.  return path.size() == 0
  3.    ? tail == null ? Optional.empty() : Optional.of(Route.normalize(tail))
  4.    : Optional.of(path.stream()
  5.    .collect(Collectors.joining("", "", tail == null
  6.      ? "" : Route.normalize(tail))));
  7. }

代码示例来源：origin: graphhopper/graphhopper

  1. @Override
  2. public int getNodes() {
  3.   return IntStream.concat(
  4.       IntStream.of(graphHopperStorage.getNodes()-1),
  5.       additionalEdges.stream().flatMapToInt(edge -> IntStream.of(edge.getBaseNode(), edge.getAdjNode())))
  6.       .max().getAsInt()+1;
  7. }

代码示例来源：origin: jooby-project/jooby

  1. @Override public void enterMvcRoute(final FuzzyDocParser.MvcRouteContext ctx) {
  2.  String path = pattern(ctx.annotations);
  3.  List<String> methods = methods(ctx.annotations);
  4.  if (methods.isEmpty() && path == null) {
  5.   // not an mvc method
  6.   return;
  7.  }
  8.  String comment = ctx.doc.getText();
  9.  String pattern =
  10.    prefix.stream().collect(Collectors.joining()) + "/" + Optional.ofNullable(path)
  11.      .orElse("/");
  12.  if (methods.size() == 0) {
  13.   doc.add(doc("get", normalize(pattern), file, summary(), comment));
  14.  } else {
  15.   methods.stream()
  16.     .forEach(method -> doc.add(doc(method, normalize(pattern), file, summary(), comment)));
  17.  }
  18. }

代码示例来源：origin: jooby-project/jooby

  1. @Override public void enterScript(final FuzzyDocParser.ScriptContext ctx) {
  2.  if (ctx.dot == null && !insideRoute()) {
  3.   /**
  4.    * reset prefix when '.' is missing:
  5.    *
  6.    * use("prefix")
  7.    *   .get()
  8.    *
  9.    * vs
  10.    *
  11.    * get("pattern")
  12.    *
  13.    * but ignore dot when route(prefix) is present (kotlin)
  14.    */
  15.   popPrefix();
  16.   popSummary();
  17.  }
  18.  String comment = Optional.ofNullable(ctx.doc).map(it -> it.getText()).orElse("");
  19.  if (ctx.method != null) {
  20.   String method = ctx.method.getText();
  21.   String pattern =
  22.     prefix.stream().collect(Collectors.joining("")) + "/" + Optional.ofNullable(ctx.pattern)
  23.       .map(it -> str(it.getText()))
  24.       .orElse("/");
  25.   doc.add(doc(method, normalize(pattern), file, summary(), comment));
  26.  }
  27. }

代码示例来源：origin: jersey/jersey

  1. varyHeaderValue.set(varyValue);
  2. return vhs.stream()
  3.      .map(variantHolder -> variantHolder.v)
  4.      .collect(Collectors.toList());

代码示例来源：origin: jersey/jersey

  1. varyHeaderValue.set(varyValue);
  2. return vhs.stream()
  3.      .map(variantHolder -> variantHolder.v)
  4.      .collect(Collectors.toList());

代码示例来源：origin: Netflix/Priam

  1. private void retrieveAndUpdate(final BackupMetadata backupMetadata) {
  2.   // Retrieve the snapshot metadata and then update the date/status.
  3.   LinkedList<BackupMetadata> metadataLinkedList = locate(backupMetadata.getSnapshotDate());
  4.   if (metadataLinkedList == null) {
  5.     logger.error(
  6.         "No previous backupMetaData found. This should not happen. Creating new to ensure app keeps running.");
  7.     metadataLinkedList = new LinkedList<>();
  8.     backupMetadataMap.put(backupMetadata.getSnapshotDate(), metadataLinkedList);
  9.   }
  10.   Optional<BackupMetadata> searchedData =
  11.       metadataLinkedList
  12.           .stream()
  13.           .filter(backupMetadata1 -> backupMetadata.equals(backupMetadata1))
  14.           .findFirst();
  15.   if (!searchedData.isPresent()) {
  16.     metadataLinkedList.addFirst(backupMetadata);
  17.   }
  18.   searchedData.ifPresent(
  19.       backupMetadata1 -> {
  20.         backupMetadata1.setCompleted(backupMetadata.getCompleted());
  21.         backupMetadata1.setStatus(backupMetadata.getStatus());
  22.         backupMetadata1.setCassandraSnapshotSuccess(
  23.             backupMetadata.isCassandraSnapshotSuccess());
  24.         backupMetadata1.setSnapshotLocation(backupMetadata.getSnapshotLocation());
  25.         backupMetadata1.setLastValidated(backupMetadata.getLastValidated());
  26.       });
  27. }

代码示例来源：origin: hibernate/hibernate-orm

  1. /**
  2.  * This seems a little trivial, but we need to guarantee that all Dialects start their sequences on a non-0 value.
  3.  */
  4. @Test
  5. @TestForIssue(jiraKey = "HHH-8814")
  6. @RequiresDialectFeature(DialectChecks.SupportsSequences.class)
  7. @SkipForDialect(
  8.     value = SQLServer2012Dialect.class,
  9.     comment = "SQLServer2012Dialect initializes sequence to minimum value (e.g., Long.MIN_VALUE; Hibernate assumes it is uninitialized."
  10. )
  11. public void testStartOfSequence() throws Exception {
  12.   Session s = openSession();
  13.   Transaction tx = s.beginTransaction();
  14.   final Person person = new Person();
  15.   s.persist( person );
  16.   tx.commit();
  17.   s.close();
  18.   assertTrue( person.getId() > 0 );
  19.   assertTrue( sqlStatementInterceptor.getSqlQueries()
  20.             .stream()
  21.             .filter( sql -> sql.contains( "product_sequence" ) )
  22.             .findFirst()
  23.             .isPresent() );
  24. }

内容来源于网络，如有侵权，请联系作者删除！

LinkedList

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    LinkedList类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com