missinterpret.flows.core — io.github.missinterpret/flows 1.0.27

conj-default-flow clj

(conj-default-flow coll flow opts)

conj-leave-flow clj

(conj-leave-flow coll flow)

connect-node clj

(connect-node {:workflow/keys [log-fn] :as workflow} node args)

Connects the sink of one flow as the source of the next updating the workflow.

Note: This operates on the inverse of the convention for streams. i.e. source

flowify clj

(flowify arg & {:flow/keys [expand] :or {expand false} :as opts})

Converts the argument into an appropriate flow.

• flow or workflow: pass-through
• fn: returns a fn-flow (optionally uses result pipelining via expand-flow)
• else: throws an anomaly

fn-flow clj

(fn-flow fn-arg & opts)

Returns a flow map for a fn which wraps its execution to conform to the stream model.

has-embedded-workflows? clj

(has-embedded-workflows? node)

interceptor-order clj

(interceptor-order definition & opts)

When :flow/order is :interceptor the function adds the leave-fn of all flows which are set to the end of the definition in reverse order of appearance to follow the interceptor chain logic.

See: http://pedestal.io/pedestal/0.7/guides/what-is-an-interceptor.html#_transition_from_enter_to_leave

linear-order clj

(linear-order definition & opts)

set-log-fn clj

(set-log-fn wf log-fn)

unload-workflow clj

(unload-workflow wf)

validate-topology clj

(validate-topology definition)

Checks that the entries of the workflow definition to be processed by workflow-factory is a seq, isn't empty, has a recognized type, any dependent workflow is loaded.