問題タブ [akka-stream]

SinkSourceとを提供する をSink探していますSource。要素がそれに流れ込む場合Sink、対応する で提供する必要がありますSource。次のコードは、私が何を意味するかを示しています。

実行すると、次のように表示されます: 12345
So, does a SinkSourceexist (haven't seen it in the API) or does someone know how to implement it? Sinkandへの別個のアクセスが必要であることを言及する必要があるSourceためFlow、これはこの特定の形式では解決策ではありません。

私は Akka Stream をいじっており、実体化後の柔軟性を理解しようとしています。

これを行う 1 つの方法は、低レベルのリアクティブ ストリーム API を使用することです: http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-M3/#akka.stream.scaladsl.PublisherSource

ただし、パブリッシュまたはサブスクライブするこれらのポイントを定義する必要があります。任意のマテリアライズド フロー グラフ ノードを公開またはサブスクライブする方法はありますか? マテリアライズド フロー グラフはアクターの集まりにすぎないため、これは可能です。

例: 最初に、フロー グラフ 1 をデプロイします: A ~> B ~> C

次に、フロー グラフ 2 と 3 をデプロイします: D ~> BB ~> E

Flow.apply(Sink, Source)ドキュメントによると：

切断されているように見えるソースとシンクのペアからフローを作成します。

それが本当なら、なぜグラフはつながっていないのですか?

私が管理していない Java ライブラリのデータ パブリッシャーを使用しています。パブリッシャー ライブラリは、一般的なコールバック セットアップを使用します。ライブラリコードのどこかに（ライブラリはJavaですが、簡潔にするためにscalaで説明します）：

ライブラリのユーザーは、メソッドを実装するクラスを作成し、onDataそれを に渡す必要がDataProducerあります。ライブラリ コードは次のようになります。

にDataProducerは、制御できない独自の内部スレッドと、消費するonData別のオブジェクトがあるたびに呼び出される付随するデータ バッファーがあります。DataType

だから、私の質問は: 元のライブラリ パターンを akka ストリームのSourceオブジェクトに変換/変換するレイヤーをどのように作成すればよいですか?

前もって感謝します。

ActorPublisherをAkka-Stream として使用していSourceます。入力アクターに予想通りの名前を付けて、アプリケーションの他の部分からメッセージを送信できるようにする方法がわかりません。ソースを次のようにインスタンス化しています。

ストリームをActorRef実体化するとエラーが発生しますが、そのパスは動的に生成され、コードで生成されたフロー中心の命名スキームの一部として提供された名前のみを使用します。

このフロントエンドのアクター ソースに明示的な名前を付ける方法はありますか?

明示的に名前を付けられない場合、Akka-Stream をリモートで直接使用できないということですか?

編集:相対パスを使用して自分のアクターを見つけることができますがFlow、問題のアクターへのフルパスがどうなるかを理解できるように、自分の名前を付ける方法を理解する必要があります。

編集：（以下のakkaバージョン情報、scala 2.11.6）

編集: akka-user google グループの友好的な人々が私に啓蒙し、これに対処する適切な方法は、呼び出し自体ActorRefの結果であるを使用せずに渡すことであると示唆しています。この状況が将来変化することがわかった場合は、この質問を更新します。読んでくれてありがとう。runWith().actorSelection()

私はslick 3.0を使用しており、databasepublisherオブジェクトを次のように持っています

次のように、残りのレイヤーに akka-http を使用しています。

この databasepublisher オブジェクトを使用して、各行を変換 (json) し、クライアントにストリーミングするにはどうすればよいですか。助けてください。