Functions for doing events over http
Functions for doing events over http
(bus-stream bus evt-types pred)Returns SSE response for events that are received from a manifold bus.
The stream will contain all events the given types, for which pred
returns true.
Returns SSE response for events that are received from a manifold bus. The stream will contain all events the given types, for which `pred` returns `true`.
(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.
(stream->sse stream pred)Returns SSE response for events that are received from a manifold bus.
The stream will contain all events the given types, for which pred
returns true.
Returns SSE response for events that are received from a manifold bus. The stream will contain all events the given types, for which `pred` returns `true`.
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 |