Блог

Я использую библиотеку java akka stream. Мой вариант использования — мне нужно выполнить интенсивную операцию ввода-вывода над списком. итак, я использую groupedwithin для группирования элемента, а затем использую mapAsync для выполнения операции ввода-вывода над ним. Я хочу, чтобы каждый элемент списка передавался вниз. Я попытался и обнаружил, что мы можем использовать mapConcat (identity) для достижения этой цели, но эквивалент identity отсутствует в java. Пожалуйста, предложите мне какой-нибудь подход к этому варианту использования?

 Source.<x>queue()
    .groupedWithin(100, batchInterval)
    .mapAsync(10,A::B) // will return list
    .mapConcat(?)      // looking for equivalent of identity in akka
    .map(C::D)         // accept single element
 

Я обнаружил, что мы можем это сделать

 mapConcat(list -> list)
 

Это правильный способ использования mapConcat?