Package com.couchbase.client.core.util
Interface ReactorOps
- All Known Implementing Classes:
CoreEnvironment
-
Method Summary
Modifier and TypeMethodDescriptionstatic <T> T
proxyToPublishOnSuppliedScheduler
(T obj, Class<T> interfaceToProxy, Supplier<Scheduler> scheduler) Returns a dynamic proxy for the given object (unless the given supplier is null, in which case the same object is returned).default <T> Mono
<T> publishOnUserScheduler
(Supplier<CompletableFuture<T>> future) <T> Flux
<T> publishOnUserScheduler
(Flux<T> mono) <T> Mono
<T> publishOnUserScheduler
(Mono<T> mono)
-
Method Details
-
publishOnUserScheduler
-
publishOnUserScheduler
-
publishOnUserScheduler
-
proxyToPublishOnSuppliedScheduler
@Internal static <T> T proxyToPublishOnSuppliedScheduler(T obj, Class<T> interfaceToProxy, @Nullable Supplier<Scheduler> scheduler) Returns a dynamic proxy for the given object (unless the given supplier is null, in which case the same object is returned).Any Flux or Mono instances returned by the proxied interface methods are published on the scheduler returned by the given supplier.
-