package?ch03.pipesfilteres;

import?java.util.ArrayDeque;

public?class?DataSink?extends?Filter{
	private	FilterImpl?observer;
	
	protected?ArrayDeque?received?=?new?ArrayDeque（）;
	
	public?DataSink（Pipe?in）?{
		super（innull）;
		observer?=?null;
	}
	public?int?size（）?{
		return?received.size（）;
	}
	
	public?Packet?nextPacket（）?{
		Packet?p?=?received.getLast（）;
		received.pollLast（）;
		return?p;
	}
	public?void?customNotify（）?{
		try?{
			while（input.size（）?>?0）?{
				received.addFirst（input.read（））;
			}
		}?catch?（EmptyPipeException?e）?{
			System.err.println（“?empty?pipe.?“）;
		}
		if（observer?!=?null）
			observer.customNotify（）;
	}

	public?void?setObserver（FilterImpl?observer）?{
		this.observer?=?observer;
	}
	public?FilterImpl?getObserver（）?{
		return?observer;
	}
	@Override
	public?void?process（）?{
		try?{
			int?i=0;
			for（i=0;i<4;i++）{
				System.out.println（input.read（）+“已經(jīng)進(jìn)入了數(shù)據(jù)池“）;
				}
			
		}?catch?（EmptyPipeException?e）?{
			e.printStackTrace（）;
		}
		
	}
}

?屬性????????????大小?????日期????時(shí)間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2012-11-20?19:40??pipesfilteres\
?????文件????????1067??2012-11-20?19:38??pipesfilteres\DataSink.java
?????文件?????????428??2012-11-20?19:33??pipesfilteres\DataSource.java
?????文件??????????89??2012-11-20?19:39??pipesfilteres\EmptyPipeException.java
?????文件?????????224??2012-09-10?17:34??pipesfilteres\Filter.java
?????文件?????????544??2012-11-20?19:35??pipesfilteres\FilterImpl.java
?????文件??????????93??2012-09-10?15:41??pipesfilteres\NoOutputPipeException.java
?????文件?????????335??2012-11-20?18:35??pipesfilteres\Packet.java
?????文件?????????535??2012-11-20?19:33??pipesfilteres\Pipe.java
?????文件?????????472??2012-11-20?19:35??pipesfilteres\TestPipes.java