@ Override public Chunk < byte [ ] , BytesReference > readChunk ( ) throws IOException { Chunk < byte [ ] , BytesReference > chunk = internalReadChunk ( ) ; if ( chunk != null ) { processChunk ( chunk ) ; } return chunk ; }
Read next chunk from this stream .