Process a stream of text data and emit each whole document from the stream as soon as it is available.