v1.0.0
Pipe data through a stream until some fixed length is reached, then callback.
Source code on GitHub