(cleanup this state)Destroy any transient state created by init for a particular send.
Destroy any transient state created by init for a particular send.
(init this args)Initialize any transient state specific to a particular send.
Initialize any transient state specific to a particular send.
(run this state source)Provides the source seq/chan and lets the provider begin processing.
Provides the source seq/chan and lets the provider begin processing.
(source this state)Return a sequential collection of source records that will be fed into the pipeline.
Return a sequential collection of source records that will be fed into the pipeline.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |