Streaming single element from list in akka stream using java api

Question

I am using akka stream java library. My use case is I need to do IO intensive operation on list. so I am using groupedwithin to group element and then using mapAsync to do io operation on it. I want each element of the list to stream downwards. I tried and found that we can use mapConcat(identity) to achieve this but equivalent to identity is not present in java. Please suggest me some approach to go with this use case?

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

I found that we can do this

mapConcat(list -> list)

Is this the correct way of using mapConcat?

question from:https://stackoverflow.com/questions/66051139/streaming-single-element-from-list-in-akka-stream-using-java-api

Answer 1

Waitting for answers