Through stream that buffers data for at least x milliseconds - View it on GitHub