Functions for doing events over http
Functions for doing events over http
(bus-stream bus evt-type pred)Returns SSE response for events that are received from a manifold bus.
The stream will contain all events of given type, for which pred
returns true.
Returns SSE response for events that are received from a manifold bus. The stream will contain all events of given type, for which `pred` returns `true`.
(event-stream events evt-filter)Sets up an event stream for the specified filter.
Sets up an event stream for the specified filter.
(event-stream-listener stream)Creates an event stream listener function. When invoked with an event, puts it on the stream.
Creates an event stream listener function. When invoked with an event, puts it on the stream.
(mailman-stream broker pred)Sets up an event stream using a mailman listener. It consumes events from the configured topic and returns them as an SSE stream. The predicate is applied to the stream events before they are sent to the client.
Sets up an event stream using a mailman listener. It consumes events from the configured topic and returns them as an SSE stream. The predicate is applied to the stream events before they are sent to the client.
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 |