Package com.apple.foundationdb.clientlog

Class DatabaseClientLogEvents.EventRunner

java.lang.Object

com.apple.foundationdb.clientlog.DatabaseClientLogEvents.EventRunner

All Implemented Interfaces:

FDBClientLogEvents.AsyncConsumer<FDBClientLogEvents.Event>, FDBClientLogEvents.EventConsumer

Enclosing class:

DatabaseClientLogEvents

protected static class DatabaseClientLogEvents.EventRunner
extends Object
implements FDBClientLogEvents.EventConsumer

Constructor Summary

Constructors

Constructor	Description
EventRunner(Database database, Executor executor, DatabaseClientLogEvents.EventConsumer callback, DatabaseClientLogEvents events, int eventCountLimit, long timeLimitMillis)
EventRunner(Database database, Executor executor, DatabaseClientLogEvents.EventConsumer callback, Function<ReadTransaction,CompletableFuture<Long[]>> versionRangeProducer, int eventCountLimit, long timeLimitMillis)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	accept(FDBClientLogEvents.Event event)
boolean	more()	Determine whether to continue processing events.
CompletableFuture<DatabaseClientLogEvents>	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EventRunner

public EventRunner(@Nonnull
 Database database,
 @Nonnull
 Executor executor,
 @Nonnull
 DatabaseClientLogEvents.EventConsumer callback,
 @Nonnull
 Function<ReadTransaction,CompletableFuture<Long[]>> versionRangeProducer,
 int eventCountLimit,
 long timeLimitMillis)

EventRunner

public EventRunner(@Nonnull
 Database database,
 @Nonnull
 Executor executor,
 @Nonnull
 DatabaseClientLogEvents.EventConsumer callback,
 @Nonnull
 DatabaseClientLogEvents events,
 int eventCountLimit,
 long timeLimitMillis)

Method Details

run

public CompletableFuture<DatabaseClientLogEvents> run()

accept

public CompletableFuture<Void> accept(FDBClientLogEvents.Event event)

Specified by:

accept in interface FDBClientLogEvents.AsyncConsumer<FDBClientLogEvents.Event>

more

public boolean more()

Description copied from interface: FDBClientLogEvents.EventConsumer

Determine whether to continue processing events.

Specified by:

more in interface FDBClientLogEvents.EventConsumer

Returns:

true if more events should be processed