The general implementation approach was based off of `StreamZip` from the `async` package.