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

ExchangeAck

object ExchangeAck

Functions

Link copied to clipboard
inline fun <T : MessageExchange<*, *>> Flux<T>.filterThenAck(crossinline predicate: (T) -> Boolean): Flux<T>
Link copied to clipboard
fun Flux<*>.finallyAck(exchange: MessageExchange<*, *>): Mono<Void>
fun Mono<*>.finallyAck(exchange: MessageExchange<*, *>): Mono<Void>