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 is a website building & hosting documentation for Clojure/Script libraries
× close