vlambda博客
学习文章列表

Stream Builder 界面使其真正易于创建< /span> 轻松实现 Stream 实例。看看下面的例子：

  fun main(args: Array<String>) { 
      val stream = Stream.builder<String>() 
              .add("Item 1") 
              .add("Item 2") 
              .add("Item 3") 
              .add("Item 4") 
              .add("Item 5") 
              .add("Item 6") 
              .add("Item 7") 
              .add("Item 8") 
              .add("Item 9") 
              .add("Item 10") 
              .build() 
      println("The Stream is ${stream.collect(Collectors.toList())}") 
  } 

输出如下：

Stream.builder() 方法返回 Streams.Builder 的实例。然后，我们使用了 Builder.add 函数； add 函数接受要构建的 stream 值的项目，并返回 Stream.Builder。 build 函数随后使用提供给构建器的项目创建了 stream 实例。

使用 Streams.empty() 创建 empty Streams 非常简单工厂方法。考虑 以下 示例：

  fun main(args: Array<String>) { 
      val emptyStream = Stream.empty<String>() 
      val item = emptyStream.findAny() 
      println("Item is $item") 
 } 

在前面的示例中，我们使用 Stream.empty() 创建了一个 emptyStream 值，然后我们使用了 findAny() 函数来获取从该 Stream 中随机选择的任何元素。 findAny() 方法返回一个 可选 值，其中包含从 Stream 中随机选择的项目，或一个空的 可选，如果流为空。

以下是上述程序的输出：

我们还可以通过将 elements 提供给 of 功能。 of 函数的工作方式类似于 RxJava/RxKotlin 中的 Observable.just 方法。

查看以下 示例：

 fun main(args: Array<String>) { 
      val stream = Stream.of("Item 1",2,"Item 3",4,5.0,"Item 6") 
      println("Items in Stream =            ${stream.collect(Collectors.toList())}") 
  } 

输出如下：

简单明了，不是吗？

我们也可以使用 Stream.generate()Stream > 工厂方法。它接受一个 lambda/supplier 实例作为参数，并在每次需要项目时使用它来生成项目。这个方法也创建了一个无限流。

考虑以下示例：

  fun main(args: Array<String>) { 
      val stream = Stream.generate { 
          //return a random number 
          (1..20).random() 
      } 
      val resultantList = stream 
              .limit(10) 
              .collect(Collectors.toList()) 
      println("resultantList = $resultantList") 
  } 

输出如下：

因此，Stream API 调用 lambda 来获取 Stream 的每个元素——太棒了。

所以，既然我们已经非常熟悉如何使用 Streams 并且我们知道原始 Streams，让我们继续前进，看看如何使用 Collectors。

我们已经看到了 Collectors.toList() 的实现。 Collectors.toList() 方法有助于将 Stream 的元素收集到 List 中。 important 这里要注意的是你不能指定哪个List 实施使用；相反，它将始终使用默认值。

Collectors.toSet() 类似 到 Collectors.toList() 方法，只是代替 List， 它将元素重新打包成一个集合。同样，使用 Collectors.toSet(), 您将无法指定要使用的集合实现。

Collectors.toCollection() 方法是 toList() 和 toSet 的补充版本();它允许您提供一个自定义集合来累积列表。

考虑下面的例子来解释它：

  fun main(args: Array<String>) { 
      val resultantSet = (0..10).asSequence().asStream() 
              .collect(Collectors.toCollection{LinkedHashSet<Int>()}) 
      println("resultantSet $resultantSet") 
  } 

输出如下：

Collectors.toMap() 函数帮助我们重新打包 将 Stream 放入  Map 实现。此功能提供了很多自定义。最简单的版本接受两个 lambda；第一个是确定 Map Entry的key，第二个lambda是确定 Map Entry的value。请注意，Stream 中的每个元素都将在 Map 中的一个条目中表示。

这两个 lambda 将在单独的迭代中获取 Stream 的每个元素，并预计会基于它们生成一个键/值。

看看下面的例子：

  fun main(args: Array<String>) { 
      val resultantMap = (0..10).asSequence().asStream() 
              .collect(Collectors.toMap<Int,Int,Int>({ 
                  it 
              },{ 
                  it*it 
              })) 
      println("resultantMap = $resultantMap") 
  } 

在这个程序中，我们使用了 Collectors.toMap() 函数的最简单版本。我们向它传递了两个 lambda，第一个确定条目的键将返回传递给它的相同值，另一方面，第二个计算并返回传递值的平方。这里要注意的重要一点是两个 lambda 将具有相同的参数。

输出如下所示：

Collectors.joining() 函数帮助你加入 Stream 的 elements ，包含字符串。它有三个可选参数，分别是——delimiter、prefix和postfix .

考虑 以下 程序示例：

  fun main(args: Array<String>) { 
      val resultantString = Stream.builder<String>() 
              .add("Item 1") 
              .add("Item 2") 
              .add("Item 3") 
              .add("Item 4") 
              .add("Item 5") 
              .add("Item 6") 
              .build() 
              .collect(Collectors.joining(" - ","Starts Here=>","<=Ends   Here")) 
 
      println("resultantString $resultantString") 
  } 

输出如下：

这个函数可以让我们将 Stream 的 elements 收集到 Map  ; 对它们进行分组时起作用。此函数与 Collectors.toMap 的基本区别在于，此函数允许您创建一个 Map  函数，也就是说，它允许您创建一个 Map 函数，该函数将保存一个 List  value 作为每个组的值。

考虑 以下 示例： 

  fun main(args: Array<String>) { 
      val resultantSet = (1..20).asSequence().asStream() 
              .collect(Collectors.groupingBy<Int,Int> { it%5 }) 
      println("resultantSet $resultantSet") 
  } 

输出如下：