Stream.of(null)
    .map(ignored -> pollChannelsRepository.findAllByPollIdAndDebugFalseOrderByIdAsc) // Получаем данные первого запроса
    .flatMap(channels -> ListUtils.partition(channels, 1000).stream()) // Разделяем на пачки для подзагрузки ответов
    .map(channels -> Pair.of(channels, channels.stream().map(c -> c.getId()).collect(Collectors.toList())))
    .map(channelsWithIds -> Pair.of(channelsWithIds.getLeft(), answerPollsRepository.findAllByPollChannelIdAndStatus(channelsWithIds.getRight(), EAnswerPoll.AnswerPollStatus.NOT_STARTED)))
    .map(channelsWithAnswers -> Pair.of(channelsWithAnswers.getLeft(), channelsWithAnswers.getRight().stream().collect(Collectors.groupingBy(a -> a.getChannelId()))))
    .flatMap(channelsWithAnswers -> channelsWithAnswers.getLeft().stream(channel -> {
        RespondentResponse resp = new RespondentResponse();
	var respodentsStream -  channelsWithAnswers.getRight().getOrDefault(channel.getId(), List.of())
	                  .stream()
	                  .map(y -> new RespondentDto<>()
	                  		.email(y.getParameters().get("mail"))
	                  		.value(y.getParameters().get(value)))

        return new RespondentResponse()
            ._id(x.getId().toString())
            .createdAt(x.getCreatedAt().getTime())
            .respondents(respodentsStream); // Предположим, что поле имеет тип stream. Если поле имеет тип iterable/collection - можно написать обертку для Stream.
    }));

 public List<RespondentResponse> responseList(Long pollId, String value) {
    var pollChannelList = pollChannelsRepository.findAllByPollIdAndDebugFalseOrderByIdAsc(pollId);
    var answerPollList = answerPollsRepository.findAllByPollChannelIdInaAndStatus(pollChannelList.stream() // O (N) для получения идентификаторов каналов
        .map(EPollChannel::getId)
        .collect(Collectors.toList()), EAnswerPoll.AnswerPollStatus.NOT_STARTED);
    var pollChannedlIdToAnswerMap = answerPollList.stream().collect(Collectors.groupingBy(y -> y.getPollChannelId()); // O (M) для получения словаря 
    return pollChannelList.stream()
        .map(x -> {
          RespondentResponse resp = new RespondentResponse();
          resp._id(x.getId().toString())
              .createdAt(x.getCreatedAt().getTime())
              .respondents(pollChannedlIdToAnswerMap.getOrDefault(x.getId(), List.of()) // O(1) поиск значения
                  .stream()
                  .map(y ->
                      new RespondentDto<>().email(y.getParameters().get("mail"))
                          .value(y.getParameters().get(value)))
                  .collect(Collectors.toList()))
          ;
          return resp;

        })
        .collect(Collectors.toList());

  }