hara.lang.type-notify
clear-oneshot-sinks
added in 4.0
(clear-oneshot-sinks {:keys [oneshots sinks]})clear all registered oneshot sinks
default-notify
added in 4.0
(default-notify)gets the default notify server
(notify/default-notify)
get-oneshot-id
added in 4.0
(get-oneshot-id {:keys [oneshots]})registers a oneshot id for the app server
get-sink
added in 4.0
(get-sink {:keys [sinks]} id)gets a sink from the notification app server
handle-notify-socket
added in 4.0
(handle-notify-socket socket app)handler for socket request
notify-server
added in 4.0
(notify-server {:keys [port], :as m})create and start notify server
notify-server:create
added in 4.0
(notify-server:create {:keys [http-port socket-port]})creates notify serve
process-message
added in 4.0
(process-message app input)processes a message recieved by the notification server
remove-listener
added in 4.0
(remove-listener notify id sink-key)removes a listener from the sink
remove-oneshot-id
added in 4.0
(remove-oneshot-id {:keys [oneshots]} id)removes a oneshot id
start-notify
added in 4.0
(start-notify app)starts both servers
(notify/start-notify +server+) => map?
start-notify-http
added in 4.0
(start-notify-http {:keys [http-port sinks http-instance], :as app})starts http server
start-notify-socket
added in 4.0
(start-notify-socket {:keys [socket-port socket-instance sinks], :as app})starts socket server
stop-notify-http
added in 4.0
(stop-notify-http {:keys [http-instance], :as app})stops http server
stop-notify-socket
added in 4.0
(stop-notify-socket {:keys [socket-instance], :as app})stops socket server
watch-oneshot
added in 4.0
(watch-oneshot app timeout & [id])returns a completable future
(notify/watch-oneshot +server+ 10) => (contains string? h/future?)