Clojurians Log v2

Thanks! I now have my mental model to always provide initial value to m/reduce. It avoids lots of errors. At least it happened to me a lot.

Yes. My confusion comes from the case where no initial value is given. When initial value is passed then it expects a normal reducing function of 2 args. If there is no initial value passed .. then clojure.core reduce would call the reducing function with 2 args (the first arg which normally would be the state is passed the first item in the collection). Missionary in this case needs an additional arity. Clojure transducers have 0 1 and 2 arities. Missionary reducer function having 0 and 2 arities is something in between.

clojure's reduce uses rf's arity 0 too, when initial state is not provided and the collection is empty

I agree we're missing a word for this kind of object, but "transducing function" doesn't type check to me, this is a standalone concept that is useful without transducers

I disagree with your naming proposition, in clojure core implementation rf is used for reducing functions (i.e. the function passed to reduce) and xf is used for transducers (i.e. reducing function transformers). Arity 0 is optional and only used when the initial state is not provided.

print-time returns a flow, it cannot be consumed with ?

use m/reduce like in the working example

Thanks @leonoel I somehow hesitated to reduce over an Infinite collection. You should document it better that m/reduce is the only was to start a flow. It is not intuitive (at least to me). Also I think reduce does not receive a reduce function as argument but a transducer function (the 0 Argument call is usually used in a transducer; a reducer function always has 2 args (result and value).

So use xf instead of rf as the variable name.

The gratis News is this: I am using chime libraey for scheduling. With missionary this need falls away. And this with better supervision. You really built a pretty powerful library!