@@ -246,6 +246,9 @@ private Compression parseCompressedMessage() {
246
246
*
247
247
* @return
248
248
* <code>true</code> if this frame's bytes weren't all consumed yet, <code>false</code> otherwise.
249
+ *
250
+ * @throws IOException
251
+ * if any of the underlying I/O operations fail.
249
252
*/
250
253
private boolean isDataAvailable () throws IOException {
251
254
return isCompressedDataAvailable () || this .frameHeaderConsumed > 0 && this .frameHeaderConsumed < HEADER_LENGTH
@@ -257,6 +260,9 @@ private boolean isDataAvailable() throws IOException {
257
260
*
258
261
* @return
259
262
* <code>true</code> if there is compressed data available, <code>false</code> otherwise.
263
+ *
264
+ * @throws IOException
265
+ * if any of the underlying I/O operations fail.
260
266
*/
261
267
private boolean isCompressedDataAvailable () throws IOException {
262
268
return this .compressorIn != null && this .compressorIn .available () > 0 ;
@@ -267,6 +273,9 @@ private boolean isCompressedDataAvailable() throws IOException {
267
273
*
268
274
* @return
269
275
* <code>true</code> if all compressed data was consumed, <code>false</code> otherwise.
276
+ *
277
+ * @throws IOException
278
+ * if any of the underlying I/O operations fail.
270
279
*/
271
280
private boolean isCompressedDataReadComplete () throws IOException {
272
281
return this .compressorIn != null && this .compressorIn .available () == 0 ;
@@ -315,15 +324,18 @@ private final int readFully(byte[] b, int off, int len) throws IOException {
315
324
/**
316
325
* Reads the exact number of requested bytes from the given {@link InputStream}, blocking if needed.
317
326
*
327
+ * @param inStream
328
+ * input stream to read from
318
329
* @param b
319
330
* the buffer into which the data is read.
320
331
* @param off
321
332
* the start offset in the destination array <code>b</code>
322
333
* @param len
323
334
* the maximum number of bytes read.
324
335
* @return the total number of bytes read into the buffer, or <code>-1</code> if there is no more data because the end of the stream has been reached.
325
- * @exception IOException
326
- * if any of the underlying I/O operations fail.
336
+ *
337
+ * @throws IOException
338
+ * if any of the underlying I/O operations fail.
327
339
*/
328
340
private final int readFully (InputStream inStream , byte [] b , int off , int len ) throws IOException {
329
341
if (len < 0 ) {
0 commit comments