Module org.neo4j.driver

Package org.neo4j.driver.internal.cursor

Class RxResultCursorImpl

java.lang.Object

org.neo4j.driver.internal.cursor.AbstractRecordStateResponseHandler

org.neo4j.driver.internal.cursor.RxResultCursorImpl

All Implemented Interfaces:

DriverResponseHandler, RxResultCursor, org.neo4j.driver.internal.FailableCursor, org.reactivestreams.Subscription

public class RxResultCursorImpl
extends AbstractRecordStateResponseHandler
implements RxResultCursor, DriverResponseHandler

Nested Class Summary

Nested classes/interfaces inherited from class org.neo4j.driver.internal.cursor.AbstractRecordStateResponseHandler

AbstractRecordStateResponseHandler.RecordState

Field Summary

Fields inherited from class org.neo4j.driver.internal.cursor.AbstractRecordStateResponseHandler

recordState

Constructor Summary

Constructors

Constructor	Description
RxResultCursorImpl(DriverBoltConnection boltConnection, Query query, org.neo4j.bolt.connection.summary.RunSummary runSummary, Throwable runError, Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer, boolean closeOnSummary, Logging logging)

Method Summary

Modifier and Type	Method	Description
void	cancel()
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()
void	onComplete()
void	onDiscardSummary(DiscardSummary summary)
void	onError(Throwable throwable)
void	onIgnored()
void	onPullSummary(PullSummary summary)
void	onRecord(List<Value> fields)
CompletionStage<Throwable>	pullAllFailureAsync(Observation parentObservation)	Pulling all unconsumed records into memory and returning failure if there is any pull errors.
void	request(long n)
CompletionStage<Void>	rollback()	Rolls back this instance by releasing connection with RESET.
CompletionStage<ResultSummary>	summaryAsync(Observation observation)

Methods inherited from class org.neo4j.driver.internal.cursor.AbstractRecordStateResponseHandler

generateGqlStatusObject, updateRecordState

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.neo4j.driver.internal.adaptedbolt.DriverResponseHandler

onBeginSummary, onCommitSummary, onLogoffSummary, onLogonSummary, onResetSummary, onRollbackSummary, onRouteSummary, onRunSummary, onTelemetrySummary

Constructor Details

RxResultCursorImpl

public RxResultCursorImpl(DriverBoltConnection boltConnection,
 Query query,
 org.neo4j.bolt.connection.summary.RunSummary runSummary,
 Throwable runError,
 Consumer<org.neo4j.driver.internal.DatabaseBookmark> bookmarkConsumer,
 boolean closeOnSummary,
 Logging logging)

Method Details

getRunError

public Throwable getRunError()

Specified by:

getRunError in interface RxResultCursor

keys

public List<String> keys()

Specified by:

keys in interface RxResultCursor

consumed

public CompletionStage<Void> consumed()

Specified by:

consumed in interface org.neo4j.driver.internal.FailableCursor

isDone

public boolean isDone()

Specified by:

isDone in interface RxResultCursor

installRecordConsumer

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

Specified by:

installRecordConsumer in interface RxResultCursor

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

summaryAsync

public CompletionStage<ResultSummary> summaryAsync(Observation observation)

Specified by:

summaryAsync in interface RxResultCursor

rollback

public CompletionStage<Void> rollback()

Description copied from interface: RxResultCursor

Rolls back this instance by releasing connection with RESET.

This must never be called on a published instance.

Specified by:

rollback in interface RxResultCursor

Returns:

reset completion stage

onComplete

public void onComplete()

Specified by:

onComplete in interface DriverResponseHandler

onError

public void onError(Throwable throwable)

Specified by:

onError in interface DriverResponseHandler

onIgnored

public void onIgnored()

Specified by:

onIgnored in interface DriverResponseHandler

onRecord

public void onRecord(List<Value> fields)

Specified by:

onRecord in interface DriverResponseHandler

onPullSummary

public void onPullSummary(PullSummary summary)

Specified by:

onPullSummary in interface DriverResponseHandler

onDiscardSummary

public void onDiscardSummary(DiscardSummary summary)

Specified by:

onDiscardSummary in interface DriverResponseHandler

discardAllFailureAsync

public CompletionStage<Throwable> discardAllFailureAsync(Observation parentObservation)

Description copied from interface: org.neo4j.driver.internal.FailableCursor

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

Specified by:

discardAllFailureAsync in interface org.neo4j.driver.internal.FailableCursor

pullAllFailureAsync

public CompletionStage<Throwable> pullAllFailureAsync(Observation parentObservation)

Description copied from interface: org.neo4j.driver.internal.FailableCursor

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

Specified by:

pullAllFailureAsync in interface org.neo4j.driver.internal.FailableCursor