javaslang.collection.List.toJavaStream()方法的使用及代码示例

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

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

List.toJavaStream介绍

暂无

代码示例

代码示例来源：origin: com.io7m.smfj/com.io7m.smfj.validation.main

private SMFParseError unparseableVersionList(
 final List<String> line,
 final Optional<Exception> exception)
{
 return this.unparseableVersion(
  line.toJavaStream().collect(Collectors.joining(" ")),
  exception);
}

代码示例来源：origin: com.io7m.smfj/com.io7m.smfj.core

private static int unsupported(
  final int bits,
  final String type,
  final List<Integer> sizes)
 {
  final StringBuilder sb = new StringBuilder(128);
  sb.append("Unsupported ");
  sb.append(type);
  sb.append(" size.");
  sb.append(System.lineSeparator());
  sb.append("  Received:  ");
  sb.append(bits);
  sb.append(System.lineSeparator());
  sb.append("  Supported: ");
  sb.append(sizes.toJavaStream()
        .map(x -> Integer.toUnsignedString(x.intValue()))
        .collect(Collectors.joining("|")));
  sb.append(System.lineSeparator());
  throw new UnsupportedOperationException(sb.toString());
 }
}

代码示例来源：origin: com.io7m.smfj/io7m-smfj-core

private static int unsupported(
  final int bits,
  final String type,
  final List<Integer> sizes)
 {
  final StringBuilder sb = new StringBuilder(128);
  sb.append("Unsupported ");
  sb.append(type);
  sb.append(" size.");
  sb.append(System.lineSeparator());
  sb.append("  Received:  ");
  sb.append(bits);
  sb.append(System.lineSeparator());
  sb.append("  Supported: ");
  sb.append(sizes.toJavaStream()
        .map(x -> Integer.toUnsignedString(x.intValue()))
        .collect(Collectors.joining("|")));
  sb.append(System.lineSeparator());
  throw new UnsupportedOperationException(sb.toString());
 }
}

代码示例来源：origin: com.io7m.smfj/com.io7m.smfj.processing.api

sb.append(System.lineSeparator());
sb.append("  Received: ");
sb.append(text.toJavaStream().collect(Collectors.joining(" ")));
sb.append(System.lineSeparator());

代码示例来源：origin: com.io7m.smfj/com.io7m.smfj.validation.main

private Validation<List<SMFParseError>, SMFSchemaRequireTriangles>
parseStatementRequireTriangles(
 final List<String> line)
{
 if (line.size() == 2) {
  final String text = line.get(1);
  switch (text) {
   case "true":
    return valid(SMF_TRIANGLES_REQUIRED);
   case "false":
    return valid(SMF_TRIANGLES_NOT_REQUIRED);
   default:
    break;
  }
 }
 final StringBuilder sb = new StringBuilder(128);
 sb.append("Could not parse triangle requirement.");
 sb.append(System.lineSeparator());
 sb.append("  Expected: require-triangles (true | false)");
 sb.append(System.lineSeparator());
 sb.append("  Received: ");
 sb.append(line.toJavaStream().collect(Collectors.joining(" ")));
 sb.append(System.lineSeparator());
 return invalid(List.of(SMFParseError.of(
  this.reader.position(),
  sb.toString(),
  Optional.empty())));
}

代码示例来源：origin: com.io7m.smfj/com.io7m.smfj.validation.main

private Validation<List<SMFParseError>, SMFSchemaRequireVertices>
parseStatementRequireVertices(
 final List<String> line)
{
 if (line.size() == 2) {
  final String text = line.get(1);
  switch (text) {
   case "true":
    return valid(SMF_VERTICES_REQUIRED);
   case "false":
    return valid(SMF_VERTICES_NOT_REQUIRED);
   default:
    break;
  }
 }
 final StringBuilder sb = new StringBuilder(128);
 sb.append("Could not parse vertices requirement.");
 sb.append(System.lineSeparator());
 sb.append("  Expected: require-vertices (true | false)");
 sb.append(System.lineSeparator());
 sb.append("  Received: ");
 sb.append(line.toJavaStream().collect(Collectors.joining(" ")));
 sb.append(System.lineSeparator());
 return invalid(List.of(SMFParseError.of(
  this.reader.position(),
  sb.toString(),
  Optional.empty())));
}

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

private void parseMetaDataValues(
 final long vendor_id,
 final long schema_id,
 final long lines)
 throws Exception
{
 final ArrayList<String> saved_lines = new ArrayList<>();
 while ((long) saved_lines.size() < lines) {
  final Optional<List<String>> line_opt = super.reader.line();
  if (!line_opt.isPresent()) {
   this.onEOF();
   return;
  }
  this.log().trace("line: {}", line_opt.get());
  final List<String> line = line_opt.get();
  if (line.isEmpty()) {
   super.failExpectedGot(
    "Received an empty line.",
    "A line of Base64 encoded data.",
    "");
   return;
  }
  saved_lines.add(line.toJavaStream().collect(Collectors.joining()));
 }
 final byte[] decoded = SMFBase64Lines.fromBase64Lines(saved_lines);
 if (this.events.onMeta(vendor_id, schema_id, (long) decoded.length)) {
  this.events.onMetaData(vendor_id, schema_id, decoded);
 }
}

代码示例来源：origin: com.io7m.smfj/com.io7m.smfj.validation.main

private Validation<List<SMFParseError>, SMFSchemaIdentifier>
parseStatementIdentifier(
 final List<String> text)
{
 if (text.length() == 4) {
  try {
   final SMFSchemaName schema = SMFSchemaName.of(text.get(1));
   final int major = Integer.parseUnsignedInt(text.get(2));
   final int minor = Integer.parseUnsignedInt(text.get(3));
   return valid(SMFSchemaIdentifier.of(schema, major, minor));
  } catch (final NumberFormatException e) {
   return invalid(List.of(SMFParseError.of(
    this.reader.position(), e.getMessage(), Optional.of(e))));
  }
 }
 final StringBuilder sb = new StringBuilder(128);
 sb.append("Incorrect number of arguments.");
 sb.append(System.lineSeparator());
 sb.append(
  "  Expected: schema <schema> <version-major> <version-minor>");
 sb.append(System.lineSeparator());
 sb.append("  Received: ");
 sb.append(text.toJavaStream().collect(Collectors.joining(" ")));
 sb.append(System.lineSeparator());
 return invalid(List.of(SMFParseError.of(
  this.reader.position(),
  sb.toString(),
  Optional.empty())));
}

代码示例来源：origin: com.io7m.smfj/com.io7m.smfj.validation.main

sb.append(System.lineSeparator());
  sb.append("  Received: ");
  sb.append(line.toJavaStream().collect(Collectors.joining(" ")));
  sb.append(System.lineSeparator());
  return invalid(List.of(SMFParseError.of(
sb.append(System.lineSeparator());
sb.append("  Received: ");
sb.append(line.toJavaStream().collect(Collectors.joining(" ")));
sb.append(System.lineSeparator());
return invalid(List.of(SMFParseError.of(

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

"Incorrect number of arguments",
  "triangles",
  line.toJavaStream().collect(Collectors.joining(" ")));
 return;
  "Incorrect number of arguments",
  "metadata",
  line.toJavaStream().collect(Collectors.joining(" ")));
 return;
   e.getMessage(),
   "attribute",
   line.toJavaStream().collect(Collectors.joining(" ")));
  return;
  "Incorrect number of arguments",
  "attribute <attribute-name>",
  line.toJavaStream().collect(Collectors.joining(" ")));
 return;
 "Unrecognized command.",
 "attribute | metadata | triangles",
 line.toJavaStream().collect(Collectors.joining(" ")));
return;

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

"The first line must be a version declaration.",
"smf <version-major> <version-minor>",
line.toJavaStream().collect(Collectors.joining(" ")))));
  "Incorrect number of arguments.",
  "smf <version-major> <version-minor>",
  line.toJavaStream().collect(Collectors.joining(" ")))));
  "Cannot parse number: " + e.getMessage(),
  "smf <version-major> <version-minor>",
  line.toJavaStream().collect(Collectors.joining(" ")))));
 "Unrecognized command.",
 "smf <version-major> <version-minor>",
 line.toJavaStream().collect(Collectors.joining(" ")))));

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

private void parseHeaderCommandSchema(
 final List<String> line)
{
 if (line.size() == 5) {
  try {
   final int vendor =
    Integer.parseUnsignedInt(line.get(1), 16);
   final int schema =
    Integer.parseUnsignedInt(line.get(2), 16);
   final int schema_version_major =
    Integer.parseUnsignedInt(line.get(3));
   final int schema_version_minor =
    Integer.parseUnsignedInt(line.get(4));
   this.schema_id = SMFSchemaIdentifier.of(
    vendor, schema, schema_version_major, schema_version_minor);
  } catch (final NumberFormatException e) {
   super.failExpectedGot(
    "Could not parse number: " + e.getMessage(),
    "schema <vendor-id> <schema-id> <schema-version-major> <schema-version-minor>",
    line.toJavaStream().collect(Collectors.joining(" ")));
  }
 } else {
  super.failExpectedGot(
   "Incorrect number of arguments",
   "schema <vendor-id> <schema-id> <schema-version-major> <schema-version-minor>",
   line.toJavaStream().collect(Collectors.joining(" ")));
 }
}

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

"Expected a meta command.",
 "meta <vendor-id> <schema-id> <integer-unsigned>",
 line.toJavaStream().collect(Collectors.joining(" ")));
break;

代码示例来源：origin: com.io7m.smfj/com.io7m.smfj.validation.main

sb.append(System.lineSeparator());
sb.append("  Received: ");
sb.append(line.toJavaStream().collect(Collectors.joining(" ")));
sb.append(System.lineSeparator());
return invalid(List.of(SMFParseError.of(

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

"Incorrect number of arguments",
 "data",
 line.toJavaStream().collect(Collectors.joining(" ")));
return;
 "Unrecognized command.",
 "attribute | coordinates | data | meta | triangles | vertices | schema",
 line.toJavaStream().collect(Collectors.joining(" ")));
return;

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

private void parseMeta(
 final List<String> line)
 throws Exception
{
 if (line.length() == 4) {
  final long vendor_id =
   (long) Integer.parseUnsignedInt(line.get(1), 16);
  final long schema_id =
   (long) Integer.parseUnsignedInt(line.get(2), 16);
  final long lines =
   Long.parseUnsignedLong(line.get(3));
  this.parseMetaDataValues(vendor_id, schema_id, lines);
 } else {
  super.failExpectedGot(
   "Incorrect number of arguments",
   "meta <vendor-id> <schema-id> <integer-unsigned>",
   line.toJavaStream().collect(Collectors.joining(" ")));
 }
}

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

"Cannot parse number: " + e.getMessage(),
  "<integer-unsigned> <integer-unsigned> <integer-unsigned>",
  line.toJavaStream().collect(Collectors.joining(" ")));
 return;
 "Incorrect number of arguments",
 "<integer-unsigned> <integer-unsigned> <integer-unsigned>",
 line.toJavaStream().collect(Collectors.joining(" ")));
return;

代码示例来源：origin: com.io7m.smfj/io7m-smfj-format-text

e.getMessage(),
 "coordinates <axis> <axis> <axis> <winding-order>",
 line.toJavaStream().collect(Collectors.joining(" ")));
"Incorrect number of arguments",
"coordinates <axis> <axis> <axis> <winding-order>",
line.toJavaStream().collect(Collectors.joining(" ")));

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

List

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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