« Index of all namespaces of this project
General utility functions.
(pmax max f input output)
-- From http://stuartsierra.com/2013/12/08/parallel-processing-with-core-async Process messages from input in parallel with at most max concurrent operations. Invokes f on values taken from input channel. f must return a channel, whose first value (if not closed) will be put on the output channel. Returns a channel which will be closed when the input channel is closed and all operations have completed. Creates new operations lazily: if processing can keep up with input, the number of parallel operations may be less than max. Note: the order of outputs may not match the order of inputs.
(profile & forms)
Logs profiling information about the execution of the given forms.
(send-to-dlq! transport message)
Attempts to send the given message to the dead letter queue. The one argument version accepts a normalized message (i.e. one which contains a reference to the ingress transport) and uses the DLQ on that transport. The two argument version accepts any message (not necessarily normalized) and a transport, and uses the DLQ on the given transport. If an appropriate DLQ cannot be found, drops the message and logs an error.