We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 81c2f9f + 5cb04da commit f26c331Copy full SHA for f26c331
modules/org.restlet/src/org/restlet/engine/io/PipeStream.java
@@ -69,12 +69,12 @@ public int read() throws IOException {
69
70
final Integer value = queue.poll(QUEUE_TIMEOUT,
71
TimeUnit.SECONDS);
72
- this.endReached = (value == -1);
73
74
if (value == null) {
75
throw new IOException(
76
"Timeout while reading from the queue-based input stream");
77
} else {
+ this.endReached = (value == -1);
78
return value.intValue();
79
}
80
} catch (InterruptedException ie) {
0 commit comments