Java / Kotlin- Akka流Source.reduce如果Source中为null则不起作用

2020年4月22日 31点热度 0条评论

在Akka Streams Doku中,给出了一个Scala示例,其中包含一个空值的列表。该列表转换为Source,并像示例中那样减少。不幸的是,在Java / Kotlin中这不会输出任何内容。

通过推文链接到Scala示例:https://doc.akka.io/docs/akka/current/stream/stream-quickstart.html#first-steps

在这里,我翻译成 Kotlin

val system = ActorSystem.create("reactive-tweets")

val ints: Source<Int, NotUsed> = Source.from(listOf(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, null))
ints
  .filter {
    it != null
  }
  .map {
    it * 2
  }
  .reduce { arg1, arg2 ->
    arg1 + arg2
  }
  .runWith(Sink.foreach { a -> println("sum: " + a)}, system)

我还尝试了
Source<Int?, NotUsed>,没有进行任何更改。

我很想知道后端是否发生错误或发生了什么,表明流没有到达print语句。

解决方案如下:

Akka Streams不允许使用null元素。记录在https://doc.akka.io/docs/akka/current/stream/stream-flows-and-basics.html#illegal-stream-elements

在该示例中看到的不是null作为流元素,而是Nil用于使用::运算符构造列表。在Scala中,Nil是一个包含空列表的常量,并且::将元素添加到列表中。这些在本示例中用于构造一个链表,然后将其转换为Source