public final class SearchPagedFlux extends com.azure.core.http.rest.PagedFluxBase<SearchResult,SearchPagedResponse>
ContinuablePagedFlux
where the continuation token type is SearchRequest
, the
element type is SearchResult
, and the page type is SearchPagedResponse
.Constructor and Description |
---|
SearchPagedFlux(Supplier<Mono<SearchPagedResponse>> firstPageRetriever)
Creates an instance of
SearchPagedFlux . |
SearchPagedFlux(Supplier<Mono<SearchPagedResponse>> firstPageRetriever,
Function<String,Mono<SearchPagedResponse>> nextPageRetriever)
Creates an instance of
SearchPagedFlux . |
Modifier and Type | Method and Description |
---|---|
Mono<List<AnswerResult>> |
getAnswers()
The answer results based on the search request.
|
Mono<Double> |
getCoverage()
The percentage of the index covered in the search request.
|
Mono<Map<String,List<FacetResult>>> |
getFacets()
The facet query results based on the search request.
|
Mono<Long> |
getTotalCount()
The approximate number of documents that matched the search and filter parameters in the request.
|
byPage, byPage, getPageSize
getContinuationPredicate
all, any, as, blockFirst, blockFirst, blockLast, blockLast, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferUntil, bufferUntil, bufferUntilChanged, bufferUntilChanged, bufferUntilChanged, bufferWhen, bufferWhen, bufferWhile, cache, cache, cache, cache, cache, cache, cancelOn, cast, checkpoint, checkpoint, checkpoint, collect, collect, collectList, collectMap, collectMap, collectMap, collectMultimap, collectMultimap, collectMultimap, collectSortedList, collectSortedList, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapIterable, concatMapIterable, concatWith, concatWithValues, contextWrite, contextWrite, count, create, create, defaultIfEmpty, defer, deferContextual, deferWithContext, delayElements, delayElements, delaySequence, delaySequence, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, distinct, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnComplete, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elapsed, elapsed, elementAt, elementAt, empty, error, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMap, flatMap, flatMap, flatMapDelayError, flatMapIterable, flatMapIterable, flatMapSequential, flatMapSequential, flatMapSequential, flatMapSequentialDelayError, from, fromArray, fromIterable, fromStream, fromStream, generate, generate, generate, getPrefetch, groupBy, groupBy, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, index, index, interval, interval, interval, interval, join, just, just, last, last, limitRate, limitRate, limitRequest, log, log, log, log, log, log, map, mapNotNull, materialize, merge, merge, merge, merge, merge, merge, mergeComparing, mergeComparing, mergeComparing, mergeComparingDelayError, mergeComparingWith, mergeDelayError, mergeOrdered, mergeOrdered, mergeOrdered, mergeOrderedWith, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequentialDelayError, mergeSequentialDelayError, mergeSequentialDelayError, mergeWith, metrics, name, never, next, ofType, onAssembly, onAssembly, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureError, onBackpressureLatest, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, parallel, parallel, parallel, publish, publish, publish, publish, publishNext, publishOn, publishOn, publishOn, push, push, range, reduce, reduce, reduceWith, repeat, repeat, repeat, repeat, repeatWhen, replay, replay, replay, replay, replay, replay, retry, retry, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleTimeout, sampleTimeout, scan, scan, scanWith, share, shareNext, single, single, singleOrEmpty, skip, skip, skip, skipLast, skipUntil, skipUntilOther, skipWhile, sort, sort, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnFirst, switchOnFirst, switchOnNext, switchOnNext, tag, take, take, take, take, takeLast, takeUntil, takeUntilOther, takeWhile, then, then, thenEmpty, thenMany, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, transformDeferred, transformDeferredContextual, using, using, usingWhen, usingWhen, window, window, window, window, window, window, window, windowTimeout, windowTimeout, windowUntil, windowUntil, windowUntil, windowUntilChanged, windowUntilChanged, windowUntilChanged, windowWhen, windowWhile, windowWhile, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith, zipWith, zipWith, zipWithIterable, zipWithIterable
public SearchPagedFlux(Supplier<Mono<SearchPagedResponse>> firstPageRetriever)
SearchPagedFlux
.firstPageRetriever
- Supplied that handles retrieving SearchPagedResponses
.public SearchPagedFlux(Supplier<Mono<SearchPagedResponse>> firstPageRetriever, Function<String,Mono<SearchPagedResponse>> nextPageRetriever)
SearchPagedFlux
.firstPageRetriever
- Supplied that handles retrieving SearchPagedResponses
.nextPageRetriever
- Function that retrieves the next SearchPagedResponses
given
a continuation token.public Mono<Long> getTotalCount()
If count
is set to false
in the request this will be null
.
count
is true
, otherwise
null
.public Mono<Double> getCoverage()
If minimumCoverage
wasn't supplied in the request this will be null
.
minimumCoverage
was set in the
request, otherwise null
.public Mono<Map<String,List<FacetResult>>> getFacets()
If facets
weren't supplied in the request this will be null
.
facets
were supplied in the request, otherwise null
.public Mono<List<AnswerResult>> getAnswers()
If answers
wasn't supplied in the request this will be null.
answers
were supplied in the request, otherwise null.Copyright © 2021 Microsoft Corporation. All rights reserved.