Fork me on GitHub
Slack Archive

This page is not created by, affiliated with, or supported by Slack Technologies, Inc.

2021-12-19

Channels

#missionary
<
2021-12-19
>
Panel13:12:24

I'm looking for a way to limit the number of concurrent task run with join, kind of like the mergeAll op in Rx that take an int to limit the concurrency. Any suggestion ?

Panel13:12:44

Thanks ben should have checked the wiki first...

ribelo23:12:02

what would be the most idiomatic way to retrieve exactly one value from flow? (m/eduction (take 1)... ?

ribelo00:12:14

I would like to put the last known value from flow into dfv

Panel00:12:28

(def first-or "[pure] Task completing with first value produced by flow, or default value if empty." (partial m/reduce (comp reduced {})))

ribelo00:12:51

Oh, goldmine, why didn't I find this before?

ribelo00:12:08

thx mate ❤️

Panel00:12:52

I always go back to this example

Ben Sless06:12:32

You can also run an eduction with (take 1)

👍 1