Skip to content
This repository has been archived by the owner on Apr 5, 2022. It is now read-only.

Commit

Permalink
Streaming API
Browse files Browse the repository at this point in the history
  • Loading branch information
habuma committed May 27, 2011
2 parents 2f7f45c + ade78f6 commit 40c046e
Showing 1 changed file with 0 additions and 5 deletions.
Expand Up @@ -27,7 +27,6 @@
class StreamImpl implements Stream {

private volatile boolean open;

private final List<StreamListener> listeners;

private final InputStream inputStream;
Expand All @@ -42,9 +41,6 @@ public StreamImpl(InputStream inputStream, List<StreamListener> listeners) {
}

public void next() {
if(!open) {
throw new IllegalStateException();
}
try {
String line = reader.readLine();
if(line == null) {
Expand All @@ -61,7 +57,6 @@ public void next() {

public void close() {
try {
open = false;
inputStream.close();
} catch(IOException ignore) {}
}
Expand Down

0 comments on commit 40c046e

Please sign in to comment.