RemoteWaitNotifyPolicy

class RemoteWaitNotifyPolicy(val retry: Retry = DEFAULT_RETRY_SPEC, val scheduler: Scheduler = Schedulers.immediate())

Constructors

constructor(retry: Retry = DEFAULT_RETRY_SPEC, scheduler: Scheduler = Schedulers.immediate())

val retry: Retry

val scheduler: Scheduler

fun <T : Any> apply(publisher: Mono<T>): Mono<T>