import java.io.*;
/**類PipeStream1使用管道輸入流來獲得有關信息*/
public class PipeStream1{
	public static void main(String args[]){
		try
		{
			PipedInputStream inObj = new PipedInputStream();
			PipeStream2 classObj = new PipeStream2();
			/*下面的語句將管道輸入流和輸出流連接起來*/
			inObj.connect(classObj.outObj);
			DataInputStream receiverObj = new DataInputStream(inObj);
			String readStr;
			classObj.writeS();
			readStr = receiverObj.readUTF();
			System.out.println(readStr);
			receiverObj.close();
			classObj.close();			
		}catch(IOException e){
			System.out.println("error:"+e);
			System.exit(0);
		}
	}
}
/**類PipeStream2使用管道輸出流將有關信息寫入輸入流*/
class PipeStream2{
	PipedOutputStream outObj;
	DataOutputStream senderObj;
	/**構造方法生成管道輸出流對象*/
	public PipeStream2()
	{
		outObj = new PipedOutputStream();
	}
	/**writeS()方法將一個字符串通過管道輸出流發送*/
	public void writeS()
	{
		try
		{
			senderObj = new DataOutputStream(outObj);
			String writeStr = new String("Hi,glad to meet you!");
			senderObj.writeUTF(writeStr);
		}catch(IOException e){
			System.out.println("error:"+e);
		}
	}
	/**關閉管道輸出流*/
	public void close()
	{
		try
		{
			senderObj.close();
		}catch(IOException e){
			System.exit(0);
		}
	}
}