cms/conient/DataReader.java

//---PACKAGE DECLARATION---

//---IMPORTS---
import java.io.*;
import uk.ac.ukc.iscream.util.*;

/**
 * Reads in bound data and presents it as it comes
 * in for anything that wants it.
 *
 * @author  $Author: ajm4 $
 * @version $Id: DataReader.java,v 1.5 2001/01/20 16:06:53 ajm4 Exp $
 */
public class DataReader extends Thread {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public final String REVISION = "$Revision: 1.5 $";
   
//---STATIC METHODS---

//---CONSTRUCTORS---

    public DataReader(BufferedReader inBound, Queue dataQueue) {
        _inBound = inBound;
        _dataQueue = dataQueue;
    }

//---PUBLIC METHODS---

    public void run() {
        try {
        
            while (_running) {
                _dataQueue.add(_inBound.readLine());
            }
        
            //tidy up some stuff here at some point
            _inBound.close();
        
        } catch (IOException e) {
                SwingClient.addMessage("Data Channel Shutdown: reason - "+e);
                _running = false;
        }
    }

//---PRIVATE METHODS---

//---ACCESSOR/MUTATOR METHODS---

    public void setRunning(boolean running) {
        _running = running;
    }

//---ATTRIBUTES---

    BufferedReader _inBound;
    Queue _dataQueue;
    boolean _running = true;    
//---STATIC ATTRIBUTES---

}
Revision:	1.6
Committed:	Mon Jan 22 03:03:39 2001 UTC (23 years, 3 months ago) by ajm
Branch:	MAIN
Changes since 1.5:	+16 -9 lines
Log Message:	re-worked to be better OO... ;-) added support for V1.0 client protocol all still very messy....
#	Content
1	//---PACKAGE DECLARATION---
2
3	//---IMPORTS---
4	import java.io.*;
5	import uk.ac.ukc.iscream.util.*;
6
7	/**
8	* Reads in bound data and presents it as it comes
9	* in for anything that wants it.
10	*
11	* @author $Author: ajm4 $
12	* @version $Id: DataReader.java,v 1.5 2001/01/20 16:06:53 ajm4 Exp $
13	*/
14	public class DataReader extends Thread {
15
16	//---FINAL ATTRIBUTES---
17
18	/**
19	* The current CVS revision of this class
20	*/
21	public final String REVISION = "$Revision: 1.5 $";
22
23	//---STATIC METHODS---
24
25	//---CONSTRUCTORS---
26
27	public DataReader(BufferedReader inBound, Queue dataQueue) {
28	_inBound = inBound;
29	_dataQueue = dataQueue;
30	}
31
32	//---PUBLIC METHODS---
33
34	public void run() {
35	try {
36
37	while (_running) {
38	_dataQueue.add(_inBound.readLine());
39	}
40
41	//tidy up some stuff here at some point
42	_inBound.close();
43
44	} catch (IOException e) {
45	SwingClient.addMessage("Data Channel Shutdown: reason - "+e);
46	_running = false;
47	}
48	}
49
50	//---PRIVATE METHODS---
51
52	//---ACCESSOR/MUTATOR METHODS---
53
54	public void setRunning(boolean running) {
55	_running = running;
56	}
57
58	//---ATTRIBUTES---
59
60	BufferedReader _inBound;
61	Queue _dataQueue;
62	boolean _running = true;
63	//---STATIC ATTRIBUTES---
64
65	}