标准Kotlin库中提供了哪些Java 8 Stream.collect等效项？

标准Kotlin库中提供了哪些Java 8 Stream.collect等效项？

Kotlin
stdlib中有一些功能，用于平均，计数，不同，过滤，查找，分组，联接，映射，最小，最大，分区，切片，排序，求和，到/自数组，到/自列表，到/自地图，联合，共同迭代，所有功能范例等。因此，您可以使用它们来创建少量的1-liner，而无需使用Java8的更复杂的语法。

编辑11.08.2017： 在kotlin 1.2
M2中添加了分块/窗口收集 *** 作，请参阅https://blog.jetbrains.com/kotlin/2017/08/kotlin-1-2-m2-is-
out/

---

在创建可能已经存在的新函数之前，最好先整体探讨kotlin.collections的API参考。

这是从Java 8

Stream.collect

示例到Kotlin中的等效示例的一些转换：

将名称累积到列表中

// Java:  List<String> list = people.stream().map(Person::getName).collect(Collectors.toList());// Kotlin:val list = people.map { it.name }  // toList() not needed

将元素转换为字符串并将其连接起来，并以逗号分隔

// Java:String joined = things.stream() .map(Object::toString) .collect(Collectors.joining(", "));// Kotlin:val joined = things.joinToString(", ")

计算员工的薪金总额

// Java:int total = employees.stream().collect(Collectors.summingInt(Employee::getSalary)));// Kotlin:val total = employees.sumBy { it.salary }

按部门分组员工

// Java:Map<Department, List<Employee>> byDept     = employees.stream()     .collect(Collectors.groupingBy(Employee::getDepartment));// Kotlin:val byDept = employees.groupBy { it.department }

按部门计算薪金总额

// Java:Map<Department, Integer> totalByDept     = employees.stream()     .collect(Collectors.groupingBy(Employee::getDepartment,          Collectors.summingInt(Employee::getSalary)));// Kotlin:val totalByDept = employees.groupBy { it.dept }.mapValues { it.value.sumBy { it.salary }}

划分学生通过和失败

// Java:Map<Boolean, List<Student>> passingFailing =     students.stream()  .collect(Collectors.partitioningBy(s -> s.getGrade() >= PASS_THRESHOLD));// Kotlin:val passingFailing = students.partition { it.grade >= PASS_THRESHOLD }

男性成员的名字

// Java:List<String> namesOfMaleMembers = roster    .stream()    .filter(p -> p.getGender() == Person.Sex.MALE)    .map(p -> p.getName())    .collect(Collectors.toList());// Kotlin:val namesOfMaleMembers = roster.filter { it.gender == Person.Sex.MALE }.map { it.name }

按性别列出的成员名单名称

// Java:Map<Person.Sex, List<String>> namesByGender =      roster.stream().collect(        Collectors.groupingBy( Person::getGender, Collectors.mapping(     Person::getName,     Collectors.toList())));// Kotlin:val namesByGender = roster.groupBy { it.gender }.mapValues { it.value.map { it.name } }

将列表过滤到另一个列表

// Java:List<String> filtered = items.stream()    .filter( item -> item.startsWith("o") )    .collect(Collectors.toList());// Kotlin:val filtered = items.filter { it.startsWith('o') }

查找最短的字符串列表

// Java:String shortest = items.stream()    .min(Comparator.comparing(item -> item.length()))    .get();// Kotlin:val shortest = items.minBy { it.length }

应用过滤器后对列表中的项目进行计数

// Java:long count = items.stream().filter( item -> item.startsWith("t")).count();// Kotlin:val count = items.filter { it.startsWith('t') }.size// but better to not filter, but count with a predicateval count = items.count { it.startsWith('t') }

并继续下去…在所有情况下，都不需要模仿特殊的折叠，缩小或其他功能

Stream.collect

。如果您还有其他用例，请在注释中添加它们，我们可以看到！

关于懒惰

如果您要延迟处理链，可以在链之前转换为

Sequence

使用

asSequence()

。在功能链的最后，您通常也以一个结尾

Sequence

。然后你可以使用

toList()

，

toSet()

，

toMap()

或其他一些功能兑现的

Sequence

结尾。

// switch to and from lazyval someList = items.asSequence().filter { ... }.take(10).map { ... }.toList()// switch to lazy, but sorted() brings us out again at the endval someList = items.asSequence().filter { ... }.take(10).map { ... }.sorted()

为什么没有类型？！

您会注意到Kotlin示例未指定类型。这是因为Kotlin具有完整类型推断，并且在编译时是完全类型安全的。它比Java更是如此，因为它还具有可为空的类型，并且可以帮助防止可怕的NPE。所以在科特林：

val someList = people.filter { it.age <= 30 }.map { it.name }

是相同的：

val someList: List<String> = people.filter { it.age <= 30 }.map { it.name }

因为科特林知道什么

people

是，这

people.age

是

Int

因此，过滤器表达式只允许比较的

Int

，那

people.name

是一个

String

因此

map

步骤产生

List<String>

（只读

List

的

String

）。

现在，如果

people

是可能的

null

，因为，在一

List<People>?

则：

val someList = people?.filter { it.age <= 30 }?.map { it.name }

返回

List<String>?

需要进行空检查的a（ 或将其他Kotlin运算符之一用于可空值，请参阅此
Kotlin惯用方式来处理可空值，以及用于处理Kotlin中可空或空列表的
惯用方式 ）

也可以看看：

• 有关Iterable扩展功能的 API参考
• 数组扩展功能的 API参考
• List扩展功能的 API参考
• 用于Map扩展功能的 API参考