Scala Akka Streams 合并过滤器和映射

Question

我想知道是否有任何方法可以优化以下 Scala 代码，因为它看起来不是很有效。
基本上，我只想删除任何不是 Tweet 的对象。从流程中并将其映射到 Tweet而不是 Any .

val tweetsFlow = Flow[Any].filter({
  case _: Tweet => true
  case _ => false
}).map({
  case tweet: Tweet => tweet
})

Answer 1

您可能会使用 collect方法，有些像这样

val tws = Vector(
  "foo",
  Tweet(Author("foo"), tms, "foo #akka bar"),
  1000L,
  Tweet(Author("bar"), tms, "foo #spray bar"),
  Tweet(Author("baz"), tms, "foo bar"),
  1
)

val tflow = Flow[Any].collect {
  case x: Tweet => x
}
Source(tws).via(tflow)