Buffering BodyStream

[adeschamps]

I'm in a situation where I have a BodyStream and some function that runs on each Bytes item that it yields, and the overhead of calling that function is significant enough that it would be beneficial to buffer the input and process larger Bytes on each call. I think there are two options I could consider:

• Somehow configure the extractor so that BodyStream buffers larger chunks before my handler reads it.
• Implement buffering inside my handler.

In the first case, I'm not sure whether this is an Axum question or a Hyper question, but is there a way to configure some buffering of the input?

In the second case, this clearly isn't an Axum-specific question, although if there's any advice for buffering a stream of Result<Bytes, Error>, I'd be interested -- something involving tokio::io::BufReader seems like it's what I want, except that I think I'd be converting from Bytes to slices of u8 and back to Bytes again.