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