動的値を収集するソースを作成する方法

Question

私はドキュメントを読みましたが、何とか私は必要なソースを定義できません。 整数リストを動的に収集するソースを定義したいと思います。

デフのgetValue（M：地図[文字列、INT]）：のInt = m.getOrElse（ "＃のABCD"、0）

私は、私はそれの戻り値を収集したいと思い、この関数を呼び出すたびに。

ありがとうございました！

Answer 1

確かに100％ではありませんが、Source.queueを探している可能性があります。例：

val source: Source[Int, SourceQueueWithComplete[Int]] = 
    Source.queue[Int](16, OverflowStrategy.backpressure) 

    val sink: Sink[Int, NotUsed] = ??? 

    val queue: SourceQueueWithComplete[Int] = source.to(sink).run() 

    queue.offer(1) 
    queue.offer(2) 
    queue.offer(3) 

ドキュメントhere。