class ThreadsStream extends AbstractStream {

    @Override
    public synchronized void put(ContentEvent event) {
    	this.put(event, this.getNextCounter());
    }

    public  ThreadsStream(IProcessingItem sourcePi);

}