アッカは、私が<code>Source</code>に</p> <pre><code>val flow : FlowOps = Source(1 to 10).map(_+1) </code></pre> <p>を解析したいが、簡単な方法がないように見えるソース

Question

に

を解析ストリーム。私はこの回避策を実行しました

Source.fromGraph(

     GraphDSL.create() { builder => 

     val flow = Source(1 to 10).map(_+1) 

     SourceShape(builder.add(flow).out) 
     } 
    ) 

単純なストリームを再びグラフに変換するために、単純なストリームを変換するために過剰殺しているようです。もっと簡単な方法はありますか？

Answer 1

私が正しく理解している場合はSource[Int, _]の値としてSource(1 to 10).map(_ + 1)を使用しますか？しかし、map()は既に適切なタイプのSourceを返すので、特別なことをする必要はありません。あなただけ

val source = Source(1 to 10).map(_ + 1) 

を書く場合は、sourceはタイプSource[Int, NotUsed]を持つことになります。あなたは明示的に適切な署名を置くことによって簡単に確認できます。

val source: Source[Int, NotUsed] = Source(1 to 10).map(_ + 1) 

私はあなたがすべてでFlowOps型注釈を使用した理由さえわかりません。 FlowOpsは、scaladocが示唆しているように、akka-stream内部APIの一部であり、ライブラリ自体の外部で使用すべきではありません。