so, let’s say i want to enforce a ‘final’ action on a channel (e.g. sending the results to a destination HTTP endpoint), what would be the most idiomatic approach to do this ? my gut tells me this should probably be a reduce operation, but i’m not sure what other approaches are possible

another approach would be to use a go-loop, but that feels a bit hacky

the advantage of the reduce approach is that it also automatically closes if there is no input left, and it feels the most “functional” approach

@lmergen I read this the other day, and I like how they are terminating their pipeline https://tech.grammarly.com/blog/building-etl-pipelines-with-clojure

aha!

that’s pretty neat

i’m assuming you’re talking about that transducer / reduced? trickery

the reduced? handling is still incorrect in that blog

no, i was talking about sending the output of your pipeline to a closed channel

but you can as well use reduce without building up an accumulator

that makes me sad

and the post is using pipeline and not pipeline-blocking

I mean, it is cool that they are happy with what they did

also a stateful transducer on a channel 😞

not on a channel, on a pipeline, and pipeline might do the right thing there, I froget

the reason the outputting to a closed channel thing makes me sad is they have built this parallel processing pipeline with no way to tell when it is done

I dunno, on the one hand you want people to be happy with their choice of using clojure, on the other hand what they have shared is flawed in many ways

anyway, random blog posts on the internet are of dubious quality, who knew

All work and no play makes Jack a dull boy