Module org.neo4j.driver

Package org.neo4j.driver.internal.handlers.pulln

Class AutoPullResponseHandler

java.lang.Object

org.neo4j.driver.internal.handlers.pulln.BasicPullResponseHandler

org.neo4j.driver.internal.handlers.pulln.AutoPullResponseHandler

All Implemented Interfaces:

PullAllResponseHandler, PullResponseHandler, ResponseHandler, org.reactivestreams.Subscription

public class AutoPullResponseHandler
extends BasicPullResponseHandler
implements PullAllResponseHandler

Built on top of BasicPullResponseHandler to be able to pull in batches. It is exposed as PullAllResponseHandler as it can automatically pull when running out of records locally.

Nested Class Summary

Nested classes/interfaces inherited from class org.neo4j.driver.internal.handlers.pulln.BasicPullResponseHandler

BasicPullResponseHandler.State

Field Summary

Fields inherited from class org.neo4j.driver.internal.handlers.pulln.BasicPullResponseHandler

connection, metadataExtractor, runResponseHandler

Constructor Summary

Constructors

Constructor	Description
AutoPullResponseHandler(Query query, RunResponseHandler runResponseHandler, Connection connection, MetadataExtractor metadataExtractor, PullResponseCompletionListener completionListener, long fetchSize)

Method Summary

Modifier and Type	Method	Description
CompletionStage<ResultSummary>	consumeAsync()
<T> CompletionStage<List<T>>	listAsync(Function<Record,T> mapFunction)
CompletionStage<Record>	nextAsync()
CompletionStage<Record>	peekAsync()
void	prePopulateRecords()
CompletionStage<Throwable>	pullAllFailureAsync()

Methods inherited from class org.neo4j.driver.internal.handlers.pulln.BasicPullResponseHandler

cancel, discardAll, installRecordConsumer, installSummaryConsumer, isDone, onFailure, onRecord, onSuccess, request, state, state, writePull

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.spi.ResponseHandler

canManageAutoRead, disableAutoReadManagement, onFailure, onRecord, onSuccess

Constructor Details

AutoPullResponseHandler

public AutoPullResponseHandler(Query query,
 RunResponseHandler runResponseHandler,
 Connection connection,
 MetadataExtractor metadataExtractor,
 PullResponseCompletionListener completionListener,
 long fetchSize)

Method Details

peekAsync

public CompletionStage<Record> peekAsync()

Specified by:

peekAsync in interface PullAllResponseHandler

nextAsync

public CompletionStage<Record> nextAsync()

Specified by:

nextAsync in interface PullAllResponseHandler

consumeAsync

public CompletionStage<ResultSummary> consumeAsync()

Specified by:

consumeAsync in interface PullAllResponseHandler

listAsync

public <T> CompletionStage<List<T>> listAsync(Function<Record,T> mapFunction)

Specified by:

listAsync in interface PullAllResponseHandler

pullAllFailureAsync

public CompletionStage<Throwable> pullAllFailureAsync()

Specified by:

pullAllFailureAsync in interface PullAllResponseHandler

prePopulateRecords

public void prePopulateRecords()

Specified by:

prePopulateRecords in interface PullAllResponseHandler