Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added configurable buffer size and synchronization on the underlying stream.

Browse Source
This commit is contained in:
Mark Fisher
2008-01-12 00:32:33 +00:00
parent 133390ba07
commit 8fcb10d9be
1 changed files with 21 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
spring-integration-core/src/main/java/org/springframework/integration/adapter/stream/CharacterStreamSource.java
View File

@@ -36,20 +36,36 @@ public class CharacterStreamSource implements PollableSource<String> {
private BufferedReader reader;
private Object streamMonitor;
public CharacterStreamSource(InputStream stream) {
this.reader = new BufferedReader(new InputStreamReader(stream));
this(stream, -1);
}
public CharacterStreamSource(InputStream stream, int bufferSize) {
this.streamMonitor = stream;
if (bufferSize > 0) {
this.reader = new BufferedReader(new InputStreamReader(stream), bufferSize);
}
else {
this.reader = new BufferedReader(new InputStreamReader(stream));
}
}
public Collection<String> poll(int limit) {
List<String> results = new ArrayList<String>();
while (results.size() < limit) {
try {
boolean isReady = reader.ready();
if (!isReady) {
return results;
String line = null;
synchronized (this.streamMonitor) {
boolean isReady = reader.ready();
if (!isReady) {
return results;
}
line = reader.readLine();
}
String line = reader.readLine();
if (line == null) {
return results;
}