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?]})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; only a pre-generation previous_response_not_found for an automatic continuation can resend the original full request once.
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; only a pre-generation previous_response_not_found
for an automatic continuation can resend the original full request once.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 |