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 与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…