a transform stream that buffers up to N items, discarding on further writes - View it on GitHub