source
.viaMat(
Http().webSocketClientFlow(
WebSocketRequest(
host + "/console")
)
)(Keep.both)
.alsoTo(Sink.onComplete(_ => {
self ! RestartWebsocket
}))
.toMat(sink)(Keep.left)
.run()
--
>> Read the docs: http://akka.io/docs/
>>
Hi,
I have a problem detecting a failing websocket. I already got some help
inside the akka issue tracker, so thanks for getting me started there even
though it was the wrong place :
val source = Source.actorRef[Message](bufferSize, OverflowStrategy.fail)
val flow = Flow
