package apz.pirichat.client;
import java.io.BufferedReader;
import apz.pirichat.shared.ChatMessage;
import apz.pirichat.shared.PiriSocket;

public class InputThread extends Thread
{
    private PiriSocket mSocket;
    private BufferedReader mInputReader;

    public InputThread(BufferedReader pInputReader, PiriSocket pSocket)
    {
        mSocket = pSocket;
        mInputReader = pInputReader;
    }

    public void run()
    {
        try
        {
        while(true)
        {
            Thread.yield();
            System.out.print("> ");
            String message = mInputReader.readLine();
            ChatMessage tempMessage = new ChatMessage(mSocket.getRemoteAddress(), mSocket.getLocalAddress(), message);
            mSocket.sendMessage(tempMessage);
        }
        }
        catch(Exception e)
        {
            System.out.println(e);
        }
    }

}