package sjc;

import java.io.*;

public class ConsoleWriteThread extends Thread {
	private InputStream console;
	private OutputStream inet;
	public ConsoleWriteThread(InputStream in, OutputStream out) {
		console =in;
		inet =out;
	}
	public void run() {
		try {
			int input = -1;
			while (!isInterrupted()) {
				input = console.read();
				inet.write(input);
				inet.flush();
			}
		} catch (IOException e) {
			e.printStackTrace();
			System.out.println("Connection terminated");
			System.exit(0);
		}
	}

}