I had previously thought that NuProcess handled back-pressure. As per https://github.com/brettwooldridge/NuProcess/issues/77, it doesn't appear so. Hence, I'm reverting the code to use a Source.queue and managing a 64KiB buffer directly.
If NuProcess ever does handle back-pressure then the PublishIfAvailable source could make a come-back. It was working beautifully. :-)
I had previously thought that NuProcess handled back-pressure. As per https://github.com/brettwooldridge/NuProcess/issues/77, it doesn't appear so. Hence, I'm reverting the code to use a Source.queue and managing a 64KiB buffer directly.
If NuProcess ever does handle back-pressure then the PublishIfAvailable source could make a come-back. It was working beautifully. :-)
Requires cherry picking to master.