class ThreadsStream extends AbstractStream {

	public void addDestination(StreamDestination destination) {
		destinations.add(destination);
		maxCounter *= destination.getParallelism();
	}

	public  ThreadsStream(IProcessingItem sourcePi);

}