CrossClj

0.2.3 docs

SourceDocs



RECENT
    VARS
    milli-time
    pmax
    profile
    send-to-dlq!

    « Index of all namespaces of this project

    General utility functions.
    
    (milli-time)
    Returns System/nanoTime converted to milliseconds.
    
    (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.
    macro
    (profile & forms)
    Logs profiling information about the execution of the given forms.
    
    (send-to-dlq! message)(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.