class AssignedStreamsTasks extends AssignedTasks<StreamTask> implements RestoringTasks {

    Collection<StreamTask> restoringTasks() {
        return Collections.unmodifiableCollection(restoring.values());
    }

      AssignedStreamsTasks(final LogContext logContext);

}