ChatClientThread1.java

package Flawless_Feedback;
//Source:
//  Creating a simple Chat Client1/Server Solution 
//  http://pirate.shu.edu/~wachsmut/Teaching/CSAS2214/Virtual/Lectures/chat-client-server.html


import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;

public class ChatClientThread1 extends Thread
{

    private Socket socket = null;
    private MainForm client1 = null;
    private DataInputStream streamIn = null;


    public ChatClientThread1(MainForm _client1, Socket _socket)
    {
        client1 = _client1;
        socket = _socket;
        open();
        start();

    }

    public void open()
    {
        try
        {
            streamIn = new DataInputStream(socket.getInputStream());
        }
        catch (IOException ioe)
        {
            System.out.println("Error getting input stream: " + ioe);
            //client1.stop();
            client1.close();
        }
    }

    public void close()
    {
        try
        {
            if (streamIn != null)
            {
                streamIn.close();
            }
        }
        catch (IOException ioe)
        {
            System.out.println("Error closing input stream: " + ioe);
        }
    }

    public void run()
    {
        while (true)
        {
            try
            {
                client1.handle(streamIn.readUTF());
            }
            catch (IOException ioe)
            {
                System.out.println("Listening error: " + ioe.getMessage());
                //client1.stop();
                client1.close();
            }
        }
    }
}