Okay, I'm back! My question is just, have I designed any obviously bad races this time? I used @hiredman 's suggestion to create a buffering loop that copies from in to out. I didn't end up using a juc LinkedBlockingQueue, as I needed to surface more information than just buffer size -- I'm wondering if I'm missing some semantics that the LinkedBlockingQueue would have provided in hiredman's example. Additionally, I originally wrote this by closing over the state in the loop construction function, but I need to provide (reads from) queue-state to another page, so I def'd that state as an atom; my hope is that I have not written any race conditions there, since I only ever update that state in a single go-loop.

Is java.util.logging.Logger#log a blocking operation? There is guidelines/recommendations about core.async and logging? https://docs.oracle.com/en/java/javase/18/docs/api/java.logging/java/util/logging/Logger.html#log(java.util.logging.Level,java.lang.String)