qbits.jet.async
put!
(put! ch msg backpressure! close!)(put! ch msg backpressure!)Takes a ch, a msg, a single arg function that when passed true enables backpressure and when passed false disables it, and a no-arg function which, when invoked, closes the upstream source.