Module org.neo4j.driver

Package org.neo4j.driver.internal.cursor

Class RxResultCursorImpl

java.lang.Object

org.neo4j.driver.internal.cursor.RxResultCursorImpl

All Implemented Interfaces:

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

public class RxResultCursorImpl
extends Object
implements RxResultCursor

Constructor Summary

Constructors

Constructor	Description
RxResultCursorImpl(Throwable runError, RunResponseHandler runHandler, PullResponseHandler pullHandler, Supplier<CompletionStage<Void>> connectionReleaseSupplier)
RxResultCursorImpl(RunResponseHandler runHandler, PullResponseHandler pullHandler)

Method Summary

Modifier and Type	Method	Description
void	cancel()
CompletionStage<Throwable>	discardAllFailureAsync()	Discarding all unconsumed records and returning failure if there is any pull errors.
Throwable	getRunError()
void	installRecordConsumer(BiConsumer<Record,Throwable> recordConsumer)
boolean	isDone()
List<String>	keys()
CompletionStage<Throwable>	pullAllFailureAsync()	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()
CompletionStage<ResultSummary>	summaryStage()

Methods inherited from class java.lang.Object

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

Constructor Details

RxResultCursorImpl

public RxResultCursorImpl(RunResponseHandler runHandler,
 PullResponseHandler pullHandler)

RxResultCursorImpl

public RxResultCursorImpl(Throwable runError,
 RunResponseHandler runHandler,
 PullResponseHandler pullHandler,
 Supplier<CompletionStage<Void>> connectionReleaseSupplier)

Method Details

keys

public List<String> keys()

Specified by:

keys in interface RxResultCursor

installRecordConsumer

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

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

discardAllFailureAsync

public CompletionStage<Throwable> discardAllFailureAsync()

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()

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

summaryAsync

public CompletionStage<ResultSummary> summaryAsync()

Specified by:

summaryAsync in interface RxResultCursor

isDone

public boolean isDone()

Specified by:

isDone in interface RxResultCursor

getRunError

public Throwable getRunError()

Specified by:

getRunError 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

summaryStage

public CompletionStage<ResultSummary> summaryStage()