Exclusive Responses WebSocket leases, exposed as SSE InputStreams.
Exclusive Responses WebSocket leases, exposed as SSE InputStreams.
(close-connections!)Abort all active and idle WebSockets. Future requests can open new connections.
Abort all active and idle WebSockets. Future requests can open new connections.
(response {:keys [url headers body timeout-ms connect-timeout-ms http-client
incremental?]
:auth/keys [recover!]})Send one response.create, returning {:status 200 :body InputStream}. The body adapts JSON events to SSE; errors throw rather than become EOF. Connections are reused only after successful terminal bytes are consumed. :timeout-ms bounds response inactivity (including abandoned consumers); :connect-timeout-ms bounds the upgrade. Incremental continuation is automatic unless :incremental? false. Before any response event is observed, one known continuation, connection-limit, or recoverable server-401 rejection may resend the original full request. Connection and auth recovery use a healthy replacement socket; handshake failures are not retried here.
Send one response.create, returning {:status 200 :body InputStream}.
The body adapts JSON events to SSE; errors throw rather than become EOF.
Connections are reused only after successful terminal bytes are consumed.
:timeout-ms bounds response inactivity (including abandoned consumers);
:connect-timeout-ms bounds the upgrade. Incremental continuation is automatic
unless :incremental? false. Before any response event is observed, one known
continuation, connection-limit, or recoverable server-401 rejection may
resend the original full request. Connection and auth recovery use a healthy
replacement socket; handshake failures are not retried here.cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |