protected abstract java.util.Optional<java.util.concurrent.Callable<java.lang.Void>> |
AsyncDocumentProcessor.createTask(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
protected java.util.Optional<java.util.concurrent.Callable<java.lang.Void>> |
AsyncNodeStateProcessor.createTask(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
protected java.util.Optional<java.util.concurrent.Callable<java.lang.Void>> |
ConsistencyCheck.createTask(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
protected java.util.Optional<java.util.concurrent.Callable<java.lang.Void>> |
OrphanedNodeCheck.createTask(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
void |
CompositeDocumentProcessor.end(@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
default void |
DocumentProcessor.end(@NotNull java.util.concurrent.BlockingQueue<Result> results) |
This method is called after the last document has been processed.
|
void |
NodeCounter.end(@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
void |
Summary.end(@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
void |
AsyncDocumentProcessor.processDocument(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
void |
CompositeDocumentProcessor.processDocument(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
void |
DocumentProcessor.processDocument(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
Process the given document and publish the result to the results
queue.
|
void |
Progress.processDocument(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
void |
Summary.processDocument(@NotNull NodeDocument document,
@NotNull java.util.concurrent.BlockingQueue<Result> results) |
|
protected abstract void |
AsyncNodeStateProcessor.runTask(@NotNull Path path,
@Nullable NodeState state,
@NotNull java.util.function.Consumer<Result> resultConsumer) |
Responsibility of the subclass to implement the processor logic.
|
protected void |
NodeCounter.runTask(@NotNull Path path,
@Nullable NodeState state,
@NotNull java.util.function.Consumer<Result> resultConsumer) |
|
protected void |
ReferenceCheck.runTask(@NotNull Path path,
@Nullable NodeState state,
@NotNull java.util.function.Consumer<Result> resultConsumer) |
|