filterThenAck
inline fun <T : MessageExchange<*, *>> Flux<T>.filterThenAck(crossinline predicate: (T) -> Boolean): Flux<T>
Filters the flux and acknowledges exchanges that don't match the predicate.
For each exchange, if it matches the predicate, it passes through. If it doesn't match, it's acknowledged and filtered out.
Return
A flux containing only exchanges that match the predicate
Parameters
predicate
The predicate to test exchanges against