How to get WebSocket close code from Akka HTTP?

1
votes

We are using Akka HTTP to handle our web socket connections using the akka streams API. We are using a Flow that pipes the incoming messages to a "connection actor". A snippet of the code is below:

val connection = system.actorOf(ConnectionActor.props())

val in = Flow[Message]
  .to(Sink.actorRef[Message](connection, WebSocketClosed))

val out = Source
  .actorRef[Message](500, OverflowStrategy.fail)
  .mapMaterializedValue(ws => connection ! WebSocketOpened(ws))

Flow.fromSinkAndSource(in, out)

When the web socket is closed, the connection actor is sent the "WebSocketClose" message and we clean up internal resources. We now have the requirement to know what the reason for closing the connection was according to the standard WebSocket CloseEvent codes.

Is there a way to get the close code from Akka HTTP and send it on to the connection actor so it can take the appropriate action?

1
scalaakkaakka-streamakka-http

1 Answers

0
votes

As it turns out, this is not presently possible in Akka HTTP. See the following GitHub issue:

https://github.com/akka/akka-http/issues/2458

It looks as though this will need to be addressed before this is possible.