Использование Java 8 Stream с методом ObjectMapper readValue

Question

Я создал метод, который выполняет итерацию по списку строк и преобразует его в список POJO с использованием метода ObjectMapper readValue.

public static <T> List<T> mapPayloadListToPOJOList(List<String> payloadList, Class<T> pojo) throws IOException { 
    ObjectMapper mapper = new ObjectMapper(); 
    List<T> pojoList = new ArrayList<>(); 
    for (String payload : payloadList) { 
     T mapped = mapper.readValue(payload, pojo); 
     pojoList.add(mapped); 
    } 
    return pojoList; 
} 

1. Есть ли способ, которым я мог бы использовать Java 8 поток вместо этой реализации?
2. Не могли бы вы предоставить мне решение?

Я пытался использовать карту, но это не позволяет применить параметр Class<T>.

Answer 1

Это можно сделать очень легко, удалив цикл for и заменив его потоком, но выражения лямбда сталкиваются с некоторыми проблемами при обработке проверенных исключений.

Вы можете решить эту проблему с помощью отдельного метода преобразования и обработать исключение в этом методе (либо путем его регистрации, либо путем его сверления в виде неконтролируемого исключения).

public static <T> List<T> mapPayloadListToPOJOList(List<String> payloadList, Class<T> pojo) { 
     return payloadList.stream() 
          .map(string -> convert(string, pojo)) 
          .collect(Collectors.toList()); 
    } 

    public static <T> T convert(String string, Class<T> pojo) { 
     ObjectMapper mapper = new ObjectMapper(); 
     try { 
      return mapper.readValue(string, pojo); 
     } catch (IOException e) { 
      throw new UncheckedIOException(e); 
     } 
    } 

Answer 2

Да, проверить это link, вы можете преобразовать список в поток, а затем сопоставить каждое значение с чем-то вроде

payloadList.stream() 
    .forEach(s -> mapper.readValue(s,pojo)) 
    .collect(Collectors.toList()); 

Answer 3

Думал, что это должно было быть map, а не forEach ..

payloadList.stream() 
    .map(s -> mapper.readValue(s, pojo)) 
    .collect(Collectors.toList()) 

Разница заключается в том, что map отображает каждый элемент от оригинала List к новому элементу с использованием прилагаемой лямбда (s -> mapper.readValue(s, pojo)), тогда как forEach выполняет side-effect для каждого элемента в оригинале List, не возвращая ничего.

От Java 8 stream tutorials.