Clojurians Log v2

If I understand correctly, This is what a/alt! is for

(go
  (loop []
    (a/alt!
      c ([next-item] (process next-item) (recur))
      signal-tripped-ch :end)))

Ohh I think I completely misunderstood how alt! works until now

It's the coolest/most powerful thing in core.async :)

Thank you, TIL!

You can also just close the upstream channel

A nil from the upstream channel signals it is closed

> I can't end the channel, because it may have an arbitrary number of consumers, not all of whom should be ending

Don't mean to make more work for you, but multiple consumers and multiple producers are an anti pattern, you should use merge and tap

Can you expand on that? I usually use mult. For example, I commonly work with streams from LLM outputs represented as channels. I typically use mult to split the channel in 2, one going to the client over SSE, and the other going to a reducer that posts the reduced output to a database.

For the use case for which I asked about tap, I have a channel of data coming in from the client over websockets. Outputs from an ML streaming algorithm trigger certain async processes to either happen or stop, but I don't want to stop the data coming in from the socket, which has a lot of listeners on it

hard disagree about multiple consumers and producers being an antipattern, merge is convenient in many cases, but merge runs a normal go loop doing a copy and the behavior of doing multiple takes via alts your self vs. the indirection of merge doing it and presenting results over a channel are different.

It's a very opinionated anti pattern (and I was Wong about tap there) but I find multiple processes producing to multiple channels which are merged cleaner than multiple producers to same channel, buys you the overhead of clean shutdown

I can reopen it, don't remember why

I can imagine it not being as simple suggested in the ticket, switch from functions to macros might cause problems with the way the go macro transformation happens, or maybe the risk of breaking the build of exist projects was too high