Added simple collector so the output can be streamed, rather than collected