monkey.socket-async.core
Links core.async channels to unix domain sockets, or socket channels in general.
Links core.async channels to unix domain sockets, or socket channels in general.
read-onto-channelclj
(read-onto-channel s ch & [ex-handler])Reads EDN structures from the socket and puts them on the channel.
ch is closed on EOF. nil objects are ignored, since you can't
put nil on a channel.
If an exception is thrown while reading, it's passed to ex-handler,
which should return true in case we should continue, or false
if we should stop reading and close ch. The default behaviour
for ex-handler is to treat it like an EOF.
Reads EDN structures from the socket and puts them on the channel. `ch` is closed on EOF. `nil` objects are ignored, since you can't put `nil` on a channel. If an exception is thrown while reading, it's passed to `ex-handler`, which should return `true` in case we should continue, or `false` if we should stop reading and close `ch`. The default behaviour for `ex-handler` is to treat it like an EOF.
socket->input-streamclj
(socket->input-stream s & [ex-handler])Creates an input stream that will receive all bytes read from the socket channel. This uses a dedicated thread, so only useful if you don't have too many of these.
Creates an input stream that will receive all bytes read from the socket channel. This uses a dedicated thread, so only useful if you don't have too many of these.
writeclj
(write sock obj)Writes obj to the socket as an EDN string
Writes `obj` to the socket as an EDN string
write-from-channelclj
(write-from-channel ch s)Reads objects from the channel and writes them as EDN to the socket.
The loop will stop when ch is closed, or when an attempt to write
to s fails because the socket has been closed.
Reads objects from the channel and writes them as EDN to the socket. The loop will stop when `ch` is closed, or when an attempt to write to `s` fails because the socket has been closed.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close