@Stability.Internal public class ReactiveWaitGroup extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ReactiveWaitGroup.Waiter |
Constructor and Description |
---|
ReactiveWaitGroup(CoreTransactionAttemptContext ctx,
boolean debugMode) |
Modifier and Type | Method and Description |
---|---|
Mono<ReactiveWaitGroup.Waiter> |
add(String dbg) |
Mono<Void> |
await(Duration timeout) |
Mono<Void> |
done(ReactiveWaitGroup.Waiter waiter) |
int |
waitingCount() |
public ReactiveWaitGroup(CoreTransactionAttemptContext ctx, boolean debugMode)
public int waitingCount()
public Mono<ReactiveWaitGroup.Waiter> add(String dbg)
public Mono<Void> done(ReactiveWaitGroup.Waiter waiter)
Copyright © 2024 Couchbase, Inc.. All rights reserved.