com.deercreeklabs.talk2.ws-server — com.deercreeklabs/talk2 0.3.4

<connect clj

(<connect async-nio-ch
          rcv-ch
          send-ch
          remote-address
          conn-id
          *open?
          *server-running?
          close-conn!
          on-connect
          max-payload-len
          disable-keepalive?
          keepalive-interval-secs
          prioritized-protocols-seq
          log-improper-upgrade-requests?)

<connection-loop clj

(<connection-loop rcv-ch conn unprocessed-ba *open? *server-running?)

<keepalive-loop clj

(<keepalive-loop conn keepalive-interval-secs *open? *server-running?)

<rcv-loop clj

(<rcv-loop async-nio-ch rcv-ch close-conn! *open? *server-running?)

<send-ba! clj

(<send-ba! async-nio-ch ba)

<send-data! clj

(<send-data! {:keys [async-nio-ch data max-payload-len msg-type]})

<send-loop clj

(<send-loop {:keys [*open? *server-running? async-nio-ch close-conn!
                    max-payload-len send-ch]})

accept-loop-non-tls clj

(accept-loop-non-tls port
                     group
                     *next-conn-id
                     *server-running?
                     stop-server!
                     on-connect
                     on-disconnect
                     max-payload-len
                     disable-keepalive?
                     keepalive-interval-secs
                     prioritized-protocols-seq
                     log-improper-upgrade-requests?)

accept-loop-tls clj

(accept-loop-tls port
                 group
                 *next-conn-id
                 *server-running?
                 stop-server!
                 on-connect
                 on-disconnect
                 max-payload-len
                 disable-keepalive?
                 keepalive-interval-secs
                 prioritized-protocols-seq
                 log-improper-upgrade-requests?)

async-nio-ch-group clj

(async-nio-ch-group)

check-config clj

(check-config config)

choose-protocol clj

(choose-protocol client-protcols-set prioritized-protocols-seq)

completion-handler clj

(completion-handler on-completed on-failed)

do-connect! clj

(do-connect! async-nio-ch
             remote-address
             on-connect
             on-disconnect
             max-payload-len
             disable-keepalive?
             keepalive-interval-secs
             prioritized-protocols-seq
             *next-conn-id
             *server-running?
             log-improper-upgrade-requests?)

make-cert clj

(make-cert cert-str)

make-conn clj

(make-conn {:keys [close-conn! conn-id path protocol remote-address send-ch]})

make-group clj

(make-group ssl-ctx)

make-private-key clj

(make-private-key pkey-str)

make-ssl-ctx clj

(make-ssl-ctx cert-str pkey-str)

make-upgrade-rsp clj

(make-upgrade-rsp req-info protocol)

request-info clj

(request-info {:keys [headers first-line]} remote-address conn-id)

send! clj

(send! conn data)

(send! conn data cb)

send-ba! clj

(send-ba! async-nio-ch ba cb)

send-ping! clj

(send-ping! conn)

(send-ping! conn payload-ba)

set-on-message! clj

(set-on-message! conn f)

set-on-ping! clj

(set-on-ping! conn f)

set-on-pong! clj

(set-on-pong! conn f)

stop! clj

(stop! server)

str->input-stream clj

(str->input-stream s)

ws-server clj

(ws-server config)