A lightweight WebSocket library for ClojureScript that uses core.async.
Add the following dependency to your project.clj file:
[haslett "0.1.1"]
Haslett provides a simple and idiomatic interface to using WebSockets:
(ns example.core
(:require-macros [cljs.core.async.macros :refer [go]])
(:require [cljs.core.async :as a :refer [<! >!]]
[haslett.client :as ws]
[haslett.format :as fmt]))
(go (let [stream (<! (ws/connect "ws://echo.websocket.org"))]
(>! (:sink stream) "Hello World")
(js/console.log (<! (:source stream)))
(ws/close stream)))The connect function returns a promise channel that produces a map
with four keys: :socket, :close-status, :source and :sink.
-
:socketcontains the JavaScriptWebSocketobject, in case you need to access it directly. -
:close-statuscontains a promise channel that a status map is delivered to when the socket is closed. The status map will provide a:codeand:reasonkeys that will explain why the socket was closed. -
:sourceis a core.async channel to read from. -
:sinkis a core.async channel to write to.
By default, Haslett sends raw strings, but we can change that by supplying a formatter. Haslett includes formatters for JSON, edn and Transit:
(go (let [stream (<! (ws/connect "ws://echo.websocket.org" {:format fmt/transit}))]
(>! (:sink stream) {:foo [1 2 3]})
(js/console.log (pr-str (<! (:source stream))))
(ws/close stream)))You can customize the behaviour further by supplying your own channels for the source and sink. This allows you to tune the channel buffer, and add tranducers:
(ws/connect "ws://echo.websocket.org"
{:source (a/chan 10)
:sink (a/chan 10)})When the WebSocket is closed, the :sink and :source channels are
also closed. In addition, a final status map will be delivered to a
promise channel held in the :close-status key on the stream.
Copyright © 2017 James Reeves
Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.