through stream that buffers streams into batches limited by a cumulative byte size limit - View it on GitHub