public final class SearchIndexingBufferedAsyncSender<T> extends Object
Modifier and Type | Method and Description |
---|---|
Mono<Void> |
addActions(Collection<IndexAction<T>> actions)
Adds document index actions to the batch.
|
Mono<Void> |
addDeleteActions(Collection<T> documents)
Adds delete document actions to the batch.
|
Mono<Void> |
addMergeActions(Collection<T> documents)
Adds merge document actions to the batch.
|
Mono<Void> |
addMergeOrUploadActions(Collection<T> documents)
Adds merge or upload document actions to the batch.
|
Mono<Void> |
addUploadActions(Collection<T> documents)
Adds upload document actions to the batch.
|
Mono<Void> |
close()
Closes the buffered sender, any documents remaining in the batch will be sent to the Search index for indexing.
|
Mono<Void> |
flush()
Sends the current batch of documents to be indexed.
|
Collection<IndexAction<T>> |
getActions()
Gets the
IndexActions in the batch that are ready to be indexed. |
public Collection<IndexAction<T>> getActions()
IndexActions
in the batch that are ready to be indexed.IndexActions
in the batch that are ready to be indexed.public Mono<Void> addUploadActions(Collection<T> documents)
If the client is enabled for automatic batch sending, adding documents may trigger the batch to be sent for indexing.
documents
- Documents to be uploaded.public Mono<Void> addDeleteActions(Collection<T> documents)
If the client is enabled for automatic batch sending, adding documents may trigger the batch to be sent for indexing.
documents
- Documents to be deleted.public Mono<Void> addMergeActions(Collection<T> documents)
If the client is enabled for automatic batch sending, adding documents may trigger the batch to be sent for indexing.
documents
- Documents to be merged.public Mono<Void> addMergeOrUploadActions(Collection<T> documents)
If the client is enabled for automatic batch sending, adding documents may trigger the batch to be sent for indexing.
documents
- Documents to be merged or uploaded.public Mono<Void> addActions(Collection<IndexAction<T>> actions)
If the client is enabled for automatic batch sending, adding documents may trigger the batch to be sent for indexing.
actions
- Index actions.public Mono<Void> flush()
public Mono<Void> close()
Once the buffered sender has been closed any attempts to add documents or flush it will cause an IllegalStateException
to be thrown.
Copyright © 2021 Microsoft Corporation. All rights reserved.