1

私は Akka Streams をいじって、 を作成しFlow、それらを s を使用して接続するというアイデアを得ましたFlowGraph。

Akka のこの部分はまだ開発中であることはわかっています。そのため、いくつかのことが完了していない可能性があり、他のビットが変更される可能性がありますが、「完全」ではない (つまり、a に接続されていない) FlowGraph を作成して渡すことは可能ですかSink?フローを追加してコードのさまざまな部分を拡張し、最後にシンクを追加して完成させますか?

基本的に、FlowGraph を作成できるようにしたいのですが、方法がわかりません...特に、FlowGraph が Broadcast を使用してストリームを分割した場合。

ありがとう

4

1 に答える 1

0

来週 (12 月) は私たちのためにドキュメントを書く予定ですので、これが akka ストリームをより簡単に始めるのに役立つことを願っています! そうは言っても、ここに簡単な答えがあります：

PartialFlowGraph基本的に の代わりにが必要ですFlowGraph。それらでは、使用が許可UndefinedSinkされ、UndefinedSource後で「アタッチ」できます。あなたの場合、「欠落している」シンクが 1 つだけあるグラフを作成するための単純なヘルパー ビルダーも提供します。これらは、ソースであるかのように正確に処理できます。以下を参照してください。

  // for akka-streams 1.0-M1

  val source = Source() { implicit b ⇒
    // prepare an undefined sink, which can be relpaced by a proper sink afterwards
    val sink = UndefinedSink[Int]

    // build your processing graph
    Source(1 to 10) ~> sink

    // return the undefined sink which you mean to "fill in" afterwards
    sink
  }

  // use the partial graph (source) multiple times, each time with a different sink
  source.runWith(Sink.ignore)
  source.runWith(Sink.foreach(x ⇒ println(x)))

お役に立てれば！

于 2014-12-07T00:32:07.530 に答える