@Beta public interface ByteProcessor<T>
A callback interface to process bytes from a stream.
processBytes(byte[], int, int)
will be called for each line that is read, and should return false
when you want to stop processing.
Modifier and Type | Method and Description |
---|---|
T |
getResult()
Return the result of processing all the bytes.
|
boolean |
processBytes(byte[] buf,
int off,
int len)
This method will be called for each chunk of bytes in an input stream.
|
boolean processBytes(byte[] buf, int off, int len) throws IOException
This method will be called for each chunk of bytes in an input stream. The implementation should process the bytes from buf[off]
through buf[off + len - 1]
(inclusive).
buf
- the byte array containing the data to processoff
- the initial offset into the arraylen
- the length of data to be processedIOException
T getResult()
Return the result of processing all the bytes.