scala - 使用 Play 2.5 和服务器发送事件的命名事件流

Question

服务器发送事件中的默认事件名称/类型是“消息”。我正在尝试更改事件名称，但它不起作用。我正在使用 Play 2.5 和 akka 流。

(actorRef,sourcePublisher)=  Source
      .actorRef[T](10, OverflowStrategy.fail)
      .toMat(Sink.asPublisher(true))(Keep.both)
      .run()

backsource = Source.fromPublisher[T](sourcePublisher).named("test1")
Ok.chunked(backsource via EventSource.flow)
      .as(ContentTypes.EVENT_STREAM)

但它不会更改事件名称/类型。它仍在收听消息事件而不是test1。请建议。任何帮助表示赞赏。

Answer 1

我通过声明隐式 EventNameExtractor 解决了这个问题。下面是代码：

隐式定义对[E]：EventNameExtractor[E] = EventNameExtractor[E](p => Some(("test1")))。

有效。