So, rightly or wrongly, I did this, which seems to work:
val flow = builder.add(wsl.mapMaterializedValue(f => {
f map {
u => if (u.response.status == StatusCodes.SwitchingProtocols) {
log.info("Switched protocols")
}
else
Hi, could you please spare final code ?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives: https://groups.google.com/group/akka-user
---
You received this
Actually, I worked it out. Thanks!
On Saturday, October 15, 2016 at 12:51:10 PM UTC-4, mniel...@gmail.com
wrote:
>
> I have the following code:
>
>
> val cmdSrc: Source[Message, ActorRef] = Source.actorRef[Message](10,
> OverflowStrategy.fail)
>
> val wsr: WebSocketRequest =
