斯卡拉阿卡流合并过滤器和地图

Question

我不知道是否有什么办法来优化下面的斯卡拉代码，因为它看起来效率不高。 基本上，我只是想从流中删除任何不是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)