net.async.tcp — net.async/async 0.1.1

accept clj

(accept env at & {:as opts})

env :: result of (event-loop) at :: map of {:host <String> :port <int>}, :host defaults to wildcard address Possible opts are:

• :accept-chan :: <chan> to populate with accepted client sockets, defaults to (chan) Following options will be translated to client sockets created by accept:
• :read-chan-fn :: no-args fn returning <chan>, will be used to create :read-chan for accepted sockets
• :write-chan-fn :: no-args fn returning <chan>, will be used to create :write-chan for accepted sockets
• :heartbeat-period :: Heartbeat interval, ms. Default value is 5000
• :heartbeat-timeout :: When to consider connection stale. Default value is (* 4 heartbeat-period)

add-watches clj

(add-watches {:keys [sockets selector running?]})

buf clj

(buf size)

buf-array clj

(buf-array & xs)

client-socket clj

(client-socket socket-ref)

close-net-chan clj

(close-net-chan socket-ref)

(close-net-chan selector socket-ref)

connect clj

(connect env to & {:as opts})

env :: result of (event-loop) to :: map of {:host <String> :port <int>} Possible opts are:

• :read-chan :: <chan> to populate with reads from socket, defaults to (chan)
• :write-chan :: <chan> to schedule writes to socket, defaults to (chan)
• :heartbeat-period :: Heartbeat interval, ms. Defaults to 5000
• :heartbeat-timeout :: When to consider connection stale. Default value is (* 4 heartbeat-period)

detect-connecting clj

(detect-connecting sockets)

detect-dead clj

(detect-dead sockets)

detect-stuck clj

(detect-stuck sockets)

event-loop clj

(event-loop)

event-loop-impl clj

(event-loop-impl {:keys [sockets started? running? selector] :as env})

exhausted? clj

(exhausted? bufs)

in-thread clj

(in-thread name f & args)

inet-addr clj

(inet-addr {:keys [host port]})

new-socket clj

(new-socket opts)

now clj

(now)

on-accepted clj

(on-accepted socket-ref net-chan)

on-conn-closed clj

(on-conn-closed socket-ref)

on-conn-dropped clj

(on-conn-dropped socket-ref)

on-connected clj

(on-connected socket-ref)

on-read-ready clj

(on-read-ready socket-ref)

on-write-done clj

(on-write-done socket-ref)

select-opts clj

(select-opts socket)

shutdown! clj

(shutdown! event-loop)

write-bufs clj

(write-bufs payload)