using System;
using System.IO;
using System.Net.Sockets;
using System.Threading;

namespace WorldOfPeacecraft
{
	class Receiver
	{
		private TcpClient Client;
		private StreamReader Reader;
		private Parser Parser;
		private Thread ReceiverThread;

		public Receiver (TcpClient client, Parser parser)
		{
			this.Client = client;
			this.Parser = parser;
			ReceiverThread = new Thread(new ThreadStart(this.doReceive));
			ReceiverThread.Start();
		}

		public string Receive ()
		{
			return Reader.ReadLine ();
		}

		private void doReceive ()
		{
			this.Reader = new StreamReader (Client.GetStream ());
			while (true) {
				Parser.AddToBuffer(Receive());
			}
		}

		public void Stop()
		{
			ReceiverThread.Abort();
		}
	}
}