@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 processedIOExceptionT getResult()
Return the result of processing all the bytes.