Interface RxResultCursor

All Superinterfaces:

org.reactivestreams.Subscription

All Known Implementing Classes:

RxResultCursorImpl

public interface RxResultCursor
extends org.reactivestreams.Subscription

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	consumed()
CompletionStage<Throwable>	discardAllFailureAsync(Observation parentObservation)	Discarding all unconsumed records and returning failure if there is any pull errors.
Throwable	getRunError()
void	installRecordConsumer(BiConsumer<Record, Throwable> recordConsumer, Observation observation)
boolean	isDone()
List<String>	keys()
CompletionStage<Throwable>	pullAllFailureAsync(Observation parentObservation)	Pulling all unconsumed records into memory and returning failure if there is any pull errors.
CompletionStage<Void>	rollback()	Rolls back this instance by releasing connection with RESET.
CompletionStage<ResultSummary>	summaryAsync(Observation observation)

Methods inherited from interface org.reactivestreams.Subscription

cancel, request

Method Details

keys

List<String> keys()

installRecordConsumer

void installRecordConsumer(BiConsumer<Record, Throwable> recordConsumer,
 Observation observation)

summaryAsync

CompletionStage<ResultSummary> summaryAsync(Observation observation)

isDone

boolean isDone()

getRunError

Throwable getRunError()

rollback

CompletionStage<Void> rollback()

Rolls back this instance by releasing connection with RESET.

This must never be called on a published instance.

Returns:

reset completion stage

Since:

5.11

discardAllFailureAsync

CompletionStage<Throwable> discardAllFailureAsync(Observation parentObservation)

Discarding all unconsumed records and returning failure if there is any pull errors.

pullAllFailureAsync

CompletionStage<Throwable> pullAllFailureAsync(Observation parentObservation)

Pulling all unconsumed records into memory and returning failure if there is any pull errors.

consumed

CompletionStage<Void> consumed()