Package org.infinispan.commons.api.query.impl

Class QuerySubscription<E>

java.lang.Object

org.infinispan.commons.reactive.AbstractAsyncPublisherHandler<Query<E>,E,QueryResult<E>,QueryResult<E>>

org.infinispan.commons.api.query.impl.QuerySubscription<E>

All Implemented Interfaces:

io.reactivex.rxjava3.functions.Action, io.reactivex.rxjava3.functions.LongConsumer

public class QuerySubscription<E>
extends AbstractAsyncPublisherHandler<Query<E>,E,QueryResult<E>,QueryResult<E>>

Field Summary

Fields inherited from class org.infinispan.commons.reactive.AbstractAsyncPublisherHandler

batchSize, log, supplier

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	QuerySubscription(int maxBatchSize, Query<E> query)

Method Summary

Modifier and Type	Method	Description
protected long	handleInitialResponse(QueryResult<E> eQueryResult, Query<E> es)
protected long	handleNextResponse(QueryResult<E> eQueryResult, Query<E> es)
protected void	sendCancel(Query<E> es)
protected CompletionStage<QueryResult<E>>	sendInitialCommand(Query<E> es, int batchSize)
protected CompletionStage<QueryResult<E>>	sendNextCommand(Query<E> es, int batchSize)

Methods inherited from class org.infinispan.commons.reactive.AbstractAsyncPublisherHandler

accept, checkCancelled, handleThrowableInResponse, onNext, run, startPublisher, targetComplete

Methods inherited from class java.lang.Object

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

Constructor Details

QuerySubscription

protected QuerySubscription(int maxBatchSize,
 Query<E> query)

Method Details

sendCancel

protected void sendCancel(Query<E> es)

Specified by:

sendCancel in class AbstractAsyncPublisherHandler<Query<E>,E,QueryResult<E>,QueryResult<E>>

sendInitialCommand

protected CompletionStage<QueryResult<E>> sendInitialCommand(Query<E> es,
 int batchSize)

Specified by:

sendInitialCommand in class AbstractAsyncPublisherHandler<Query<E>,E,QueryResult<E>,QueryResult<E>>

sendNextCommand

protected CompletionStage<QueryResult<E>> sendNextCommand(Query<E> es,
 int batchSize)

Specified by:

sendNextCommand in class AbstractAsyncPublisherHandler<Query<E>,E,QueryResult<E>,QueryResult<E>>

handleInitialResponse

protected long handleInitialResponse(QueryResult<E> eQueryResult,
 Query<E> es)

Specified by:

handleInitialResponse in class AbstractAsyncPublisherHandler<Query<E>,E,QueryResult<E>,QueryResult<E>>

handleNextResponse

protected long handleNextResponse(QueryResult<E> eQueryResult,
 Query<E> es)

Specified by:

handleNextResponse in class AbstractAsyncPublisherHandler<Query<E>,E,QueryResult<E>,QueryResult<E>>