Getting and Closing a Buffer Socket

buffer-socket-utils.clj

(defn connected? [^SocketChannel client]
  (or (.isConnected client) (.isOpen client)))

(defn get-buffer-socket
  [^Integer port ^String address]
  (let [client (SocketChannel/open)
        address (InetSocketAddress. address port)]
    (.configureBlocking client true)
    (.connect client address)
    (init-buffer-socket client)))

(defn close-buffer-socket [{:keys [in out ^SocketChannel client]
                            :as   this}]
  (when (connected? client)
    (async/close! in)
    (async/close! out)
    (.shutdownInput client)
    (.shutdownOutput client)
    (.close client)
    (assoc this :client nil :in nil :out nil)))