Class MetadataAsyncIterator
java.lang.Object
org.apache.bookkeeper.bookie.datainteg.MetadataAsyncIterator
An rxjava ledger metadata iterator.
-
Constructor Summary
ConstructorsConstructorDescriptionMetadataAsyncIterator(io.reactivex.rxjava3.core.Scheduler scheduler, LedgerManager ledgerManager, int maxInFlight, int zkTimeout, TimeUnit zkTimeoutUnit) -
Method Summary
Modifier and TypeMethodDescriptionforEach(BiFunction<Long, LedgerMetadata, CompletableFuture<Void>> consumer) (package private) static Throwable
-
Constructor Details
-
MetadataAsyncIterator
MetadataAsyncIterator(io.reactivex.rxjava3.core.Scheduler scheduler, LedgerManager ledgerManager, int maxInFlight, int zkTimeout, TimeUnit zkTimeoutUnit)
-
-
Method Details
-
forEach
public CompletableFuture<Void> forEach(BiFunction<Long, LedgerMetadata, CompletableFuture<Void>> consumer) -
unwrap
-