akka-http flow handling of non-strict and strict inbound websocket messages

RippleWebSocketFlow.scala

trait InboundTransforms extends StrictLogging {

 protected def message2text(msg: Message): Future[String] = {
    msg match {
      case message: TextMessage.Strict   ⇒ Future.successful(message.text)
      case message: TextMessage.Streamed ⇒ message.textStream.runFold("")(_ + _)
      case default                       ⇒ Future.successful("Default: " + default)
    }
  }
}