私は現在、個人的なプロジェクトのためにAkka Streams(Java)で作業しています。 Source
。Source.actorRefまたはJavaのSource.queueに要素を送信する方法
アイデアはWebSocketを使用してコンテンツをユーザーのWebブラウザにプッシュすることです。私はAkka Streamsを使ってAkka HTTPのドキュメントに従って要求応答システムを作成しましたが、これは私がしたいことではありません。
Akka Streamsのドキュメントを見ると、Source.queue
とSource.actorRef
があることがわかりました。しかし、私はSource
に要素を入れる方法を理解していません。 Source.queue
およびSource.actorRef
は、offer
(Source.queue
)またはtell
(Source.actorRef
)のメソッドを持たないSource
を返します。
私の質問は:どのように私は私のSource
に要素を送ることができるように、Source.actorRef
またはSource.queue
で作成Source
ためSourceQueueWithComplete
によって作成Source
ためActorRef
を得るのですか?
私は様々なAkkaのドキュメントを検索しましたが、それを行う方法は見つけられませんでした。インターネット上で見つけたコードの大部分はScalaで書かれていますが、これは同じ問題がないようです。
可能な複製(https://stackoverflow.com [メソッドの呼び出しを介して、後の要素を受け取ることができるソースを作成する方法?]/questions/30964824/how-to-create-a-source-that-can-receive-elements-later-via-a-method-call) –