Refactor: replaced mutable buffer with Bacon streams and sleep with Bacon.bufferingThrottle