001 /*--------------------------------------------------------------------------+
002 $Id: StreamReaderThread.java 26283 2010-02-18 11:18:57Z juergens $
003 | |
004 | Copyright 2005-2010 Technische Universitaet Muenchen |
005 | |
006 | Licensed under the Apache License, Version 2.0 (the "License"); |
007 | you may not use this file except in compliance with the License. |
008 | You may obtain a copy of the License at |
009 | |
010 | http://www.apache.org/licenses/LICENSE-2.0 |
011 | |
012 | Unless required by applicable law or agreed to in writing, software |
013 | distributed under the License is distributed on an "AS IS" BASIS, |
014 | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
015 | See the License for the specific language governing permissions and |
016 | limitations under the License. |
017 +--------------------------------------------------------------------------*/
018 package edu.tum.cs.commons.io;
019
020 import java.io.BufferedReader;
021 import java.io.IOException;
022 import java.io.InputStream;
023 import java.io.InputStreamReader;
024
025 /**
026 * A thread to drain an input stream.
027 *
028 * @author Elmar Juergens
029 * @author Florian Deissenboeck
030 * @author $Author: juergens $
031 * @version $Rev: 26283 $
032 * @levd.rating GREEN Hash: 25DAC0F50BA3CBA7C86127762780A8C4
033 */
034 public class StreamReaderThread extends Thread {
035
036 /** Stream the reader reads from. */
037 private final InputStream input;
038
039 /** Content read from the stream.. */
040 private StringBuilder content;
041
042 /**
043 * Create a new reader that reads the content of this stream in its own
044 * thread. => This call is non- blocking
045 *
046 * @param input
047 * Stream to read from.
048 *
049 */
050 public StreamReaderThread(InputStream input) {
051 super();
052 this.input = input;
053 start();
054 }
055
056 /**
057 * Reads content from the stream as long as the stream is not empty.
058 */
059 @Override
060 public synchronized void run() {
061 BufferedReader reader = new BufferedReader(new InputStreamReader(input));
062
063 char[] buffer = new char[1024];
064
065 content = new StringBuilder();
066
067 try {
068 int read = 0;
069 while ((read = reader.read(buffer)) != -1) {
070 content.append(buffer, 0, read);
071 }
072 } catch (IOException e) {
073 // in case of a problem append exception description to result.
074 content.append(e);
075 }
076
077 }
078
079 /** Returns the content read from the stream. */
080 public synchronized String getContent() {
081 return content.toString();
082 }
083 }