Here's the code I'm using:

https://gist.github.com/danellis/11017d58496a80e0b0d63e2581c20d2d

When a client connects, I get this in the log:

04:05:17.732 DEBUG akka.io.TcpListener - New connection accepted 
04:05:17.866 DEBUG akka.actor.ActorSystemImpl - Creating WebSocket inbound 
actor 
04:05:17.869 DEBUG akka.actor.ActorSystemImpl - Creating WebSocket source 
04:05:17.872 DEBUG akka.actor.ActorSystemImpl - Creating WebSocket sink 

and in WireShark I see that the server returned a 101 response, but then 
immediately after that sent a FIN.

So my source and sink are being created, but my source never get 
materialized before the socket is closed for some unknown reason. I've been 
looking at this for a couple of days now, and I just can't see what's 
causing it to get closed to early. My best guess is that Akka thinks my 
Source has finished for some reason, but I don't known the Streams API well 
enough to know why that might be.

Any ideas?

-- 
>>>>>>>>>>      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 message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Reply via email to