class SchedulerJobServiceImpl implements SchedulerJobService {

	@Override
	public List<SchedulerJobData> getActiveSchedulers(String user, long minutesOffset) {
		final OffsetDateTime desiredDateTime = OffsetDateTime.now().plusMinutes(minutesOffset);
		final Predicate<SchedulerJobData> userPredicate = s -> user.equals(s.getUser());
		final Stream<SchedulerJobData> computationalSchedulersStream =
				getComputationalSchedulersForStopping(desiredDateTime, false)
						.stream()
						.filter(userPredicate);
		final Stream<SchedulerJobData> exploratorySchedulersStream =
				getExploratorySchedulersForStopping(desiredDateTime, false)
						.stream()
						.filter(userPredicate);
		return Stream.concat(computationalSchedulersStream, exploratorySchedulersStream)
				.collect(Collectors.toList());
	}

}