class SourceStreamTask extends StreamTask<OUT, OP> {

	@Override
	protected void finishTask() throws Exception {
		isFinished = true;
		cancelTask();
	}

	public  SourceStreamTask(Environment env);
	private  SourceStreamTask(Environment env, Object lock);

}