ripley.integration.manifold — io.github.tatut/ripley 2023-09-19.264

Integrate manifold deferreds and streams into ripley sources.

Requires dependency: manifold/manifold {:mvn/version "0.1.9-alpha4"}

deferred-source clj

(deferred-source d)

(deferred-source {:keys [error-value-fn]} d)

Create new source from a manifold deferred value.

Optional options can have: :error-value-fn if provided transform error into a value and send that to the source as well. By default errors are not sent.

stream-source clj

(stream-source s)

(stream-source _opts s)

Create new source that consumes values from manifold stream.