Liking cljdoc? Tell your friends :D
Clojure only.
ktest.drivers.completing-internals-driver
driverclj
(driver driver opts)This driver collects the messages that appear on the internal repartition topics and ensures that we only output the final result by pushing the repartition messages back into the topology and filtering them out of the result.
This driver collects the messages that appear on the internal repartition topics and ensures that we only output the final result by pushing the repartition messages back into the topology and filtering them out of the result.
flatten-outputclj
(flatten-output output)repartition-topic?clj
(repartition-topic? topic)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close