NewStream creates a new Producer/Consumer around a buffer.

Stream wraps a read/write buffer implementation with a channel based streaming component that satisfies the internal Benthos Consumer and Producer interfaces.

ReaderWriter is a read/write interface implemented by buffers.

AckFunc is a function used to acknowledge receipt of a message batch from a buffer.