wow-core/me.ahoo.wow.messaging.handler/ExchangeAck/filterThenAck

filterThenAck

inline fun <T : MessageExchange<*, *>> Flux<T>.filterThenAck(crossinline predicate: (T) -> Boolean): Flux<T>