.filter(MultipartReplyFlowAggregateStats.class::isInstance)
.map(multipartReplyBody ->
new AggregatedFlowStatisticsBuilder(
- MultipartReplyFlowAggregateStats.class
- .cast(multipartReplyBody))
+ (MultipartReplyFlowAggregateStats) multipartReplyBody)
.build())
.collect(Collectors.toList())))
.build();