ActorRefをSource.actorRef（）から取得するにはどうすればよいですか？

Question

ウェブアプリケーションにいくつかのサーバーサイドイベント（SSE）を実行したいと思います。私はすべてのSSEの配管を行っていると思う。私は今、家のAkka HTTP側にSourceを作成する必要があります。

は、私はあなたがこのような何かを行うことができますが見つかりました：

私は何をしたいことは、おそらく役者にメッセージを送信することにより、このソースに「公開」何とかです

val source = Source.actorRef(5, akka.stream.OverflowStrategy.dropTail) 

。私はこの呼び出しがSource<T,ActorRef>を作成することを文書から確認します。

このActorRefインスタンスを取得してメッセージを送信するにはどうすればよいですか？

Answer 1

からActorRefを取得するには、ストリームを実行する必要があります。たとえば、SSEペイロードデータ（Stringの形式）をこのアクタに送信し、そのデータをServerSentEventオブジェクトに変換してクライアントに送信するとします。何の背圧がないこと

path("events") { 
    get { 
    complete(sseSource) 
    } 
} 

注：

actor ! "quesadilla" 

そして、あなたのルートでsseSourceを使用します。今、あなたは、マテリアライズド・アクターにメッセージを送ることができます

val (actor, sseSource) = 
    Source.actorRef[String](5, akka.stream.OverflowStrategy.dropTail) 
     .map(s => /* convert String to ServerSideEvent */) 
     .keepAlive(1.second,() => ServerSentEvent.heartbeat) 
     .toMat(BroadcastHub.sink[ServerSentEvent])(Keep.both) 
     .run() 

// (ActorRef, Source[ServerSentEvent, NotUsed]) 

：あなたのような何かができますこのアプローチでは（つまり、俳優へのメッセージは発砲して忘れてしまいます）。