import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.io.PipedOutputStream;


public class ThreadB implements Runnable
{
	private PipedOutputStream pos;

	public ThreadB(PipedOutputStream pos)
	{
		this.pos = pos;
	}

	public void run()
	{
		try
		{
			BufferedReader wejscie = new BufferedReader(new FileReader("E:\\workspace\\UTP_1\\dane.txt"));
			String linijka;
			ObjectOutputStream oos = new ObjectOutputStream(pos);
			while((linijka = wejscie.readLine()) != null)
			{
				String[] tablicaDanych = linijka.split("	");
				Country element = new Country(tablicaDanych[0], tablicaDanych[1], tablicaDanych[2], tablicaDanych[3]);
				System.out.println("WYSYLANIE - START:" + element.getPanstwo());
				oos.writeObject(element);
				System.out.println("WYSYLANIE - KONIEC:" + element.getPanstwo());
			}
			oos.close();
			wejscie.close();
		}
		catch (IOException e)
		{
			e.printStackTrace();
		}
	}

}