server.clj
Branches > main > 4799394 > files / src / net / bowmap / server / network / server.clj
(ns net.bowmap.server.network.server
(:require
[clojure.core.async :refer [>!! chan close! io-thread]]
[net.bowmap.server.network.connection :as connection])
(:import
[java.net ServerSocket]))
(defn start-server!
"Starts a Minecraft server at the supplied port and bind address.
Returns a channel of connections that is coupled to the server's lifecycle."
[& {:keys [port bind-addr backlog] :or {:backlog 50 :port 0}}]
(let [server-socket (ServerSocket. port backlog bind-addr)
connection-chan (chan backlog)]
(io-thread
(try
(loop []
(when (>!! connection-chan (connection/connection (ServerSocket/.accept server-socket)))
(recur)))
(finally
(close! connection-chan)
(ServerSocket/.close server-socket))))
connection-chan))