These are chat archives for akkadotnet/AkkaStreams
Tcp.bind(…).to(Source.foreach(handleConnection)).run, so far, so good.
Source.empty, because then when I try and send anything to the socket, I immediately get "connection reset"
Source.repeat(ByteString("a"))everything works just fine, but that's hardly a solution I'd say :-)
connection.handleFlow(Flow[ByteString].alsoTo(mySink).filter(_ => false)