我想寫一個卡夫卡消費者使用反應卡夫卡，阿卡-http和akka流websocket流。 val publisherActor = actorSystem.actorOf(CommandPublisher.props)
val publisher = ActorPublisher[String](publisherActor)
val commandSource = Source
我寫了使用akka流找到Int任意源的主要成員篩子： object Sieve extends App {
implicit val system = ActorSystem()
implicit val mat = ActorMaterializer(ActorMaterializerSettings(system))
implicit val ctx = imp
我不知道是否有什麼辦法來優化下面的斯卡拉代碼，因爲它看起來效率不高。 基本上，我只是想從流中刪除任何不是Tweet的對象，並將它映射到Tweet而不是Any。 val tweetsFlow = Flow[Any].filter({
case _: Tweet => true
case _ => false
}).map({
case tweet: Tweet =>
設想一個 val myFlow: Flow[Element] = ... //some flow..
給定一個權重函數 val weightFunction: Element => Int
我想獲得 val transformedFlow: Flow[List[Element]]
使得每個元素transformationFlow是一個List [Element]，使得該列表中元素的權重