diff --git a/src/com/gearswithingears/async_sockets.clj b/src/com/gearswithingears/async_sockets.clj index 4c72d60..8af3a59 100644 --- a/src/com/gearswithingears/async_sockets.clj +++ b/src/com/gearswithingears/async_sockets.clj @@ -121,12 +121,15 @@ (async/go-loop [] (if (and (not (.isClosed java-server)) (.isBound java-server)) - (try - (async/>! conns - (init-async-socket (.accept java-server) (.getLocalSocketAddress java-server))) - (catch SocketException e - (log/error e) - (stop-socket-server public-server))) + (do + (try + (async/>! conns + (init-async-socket (.accept java-server) + (.getLocalSocketAddress java-server))) + (catch SocketException e + (log/error e) + (stop-socket-server public-server))) + (recur)) (stop-socket-server public-server))) public-server)))