listenthread.java

an instant messenger written in java (client)

import java.io.*;

class ListenThread extends Thread
{
    private BufferedReader in;
    private ThreadListener listener;
    
    public ListenThread(ThreadListener listener, InputStreamReader in)
    {
        this.listener = listener;
        this.in = new BufferedReader(in);
        this.start();
    }
    
    public void run()
    {
        String data;
        
        try
        {
            while(true)
            {
                data = in.readLine();
                if (data == null)
                {
                    listener.onDataError(2, "Lost Connection");
                    return;
                }
                else listener.onDataRev(data);
            }
        }
        catch(IOException e)
        {
            listener.onDataError(2, e.getMessage());
        }
    }
}