A way to make an async pipe?

[melekes]

Hey 👋 I am wondering if you would be interested in introducing an option of making an async pipe. I know that it could be undesirable for this repo because it seems to be focused on sync version, but I've decided to ask just in case.

We had an issue in our tests which forced me to fork the repository and introduce 4 additional methods - informalsystems/tendermint-rs#853. Would you be interested in upstreaming the changes? OR maybe we could introduce a new argument capacity: int to pipe, bipipe, pipe_buffered, bipipe_buffered (all of them or just the last two?):

capacity -1 => unbounded()
capacity 0...N => bounded(x)

what do you think?

thanks 🙏