Improved handle APIs for websockets that automatically accumulate messages etc
#1,979 opened on Apr 6, 2018
Repository metrics
- Stars
- (1,311 stars)
- PR merge metrics
- (Avg merge 1d 10h) (2 merged PRs in 30d)
Description
This is a good idea by @jrudolph to improve handling websockets:
https://github.com/akka/akka-http/pull/611#issuecomment-275113296
I think the change does what it advertises. However, I'd like to experiment with alternative APIs, instead, before people start to use toStrict (which requires to deal with futures) when an alternative could solve the issue in a simpler way.
What I'd like to try first is adding a method to UpgradeToWebSocket:
def handleStrictMessages(Graph[FlowShape[StrictMessage, Message], Any], ...)
def handleStrictTextMessages(Graph[FlowShape[TextMessage.Strict, Message], Any], ...)
def handleStrictBinaryMessages(Graph[FlowShape[BinaryMessage.Strict, Message], Any], ...)
where StrictMessage is either a new hierarchy of WS messages or a new subtype. All of these should automatically "do the right thing", i.e. accumulating streamed messages with a configured timeout and maximum size and ignore messages of the wrong shape. We could probably reuse your toStrict logic for it. Is that something you would like to help with, @rbudzko?