com.datastax.oss.dsbulk.executor.api.subscription

Class ResultSubscription<R extends Result,P extends AsyncPagingIterable<Row,P>>

java.lang.Object

com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription<R,P>

Type Parameters:

P - the page type, one of AsyncResultSet or ContinuousAsyncResultSet.

R - the result type (WriteResult or ReadResult).

All Implemented Interfaces:

Subscription

Direct Known Subclasses:

ContinuousReadResultSubscription, ReadResultSubscription, WriteResultSubscription

public abstract class ResultSubscription<R extends Result,P extends AsyncPagingIterable<Row,P>>
extends Object
implements Subscription

A single-subscriber subscription that executes the provided Statement with the provided CqlSession and emits all the rows returned by the query to its Subscriber.

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	doOnError(Throwable error)
void	request(long n)
void	start(Callable<CompletionStage<? extends P>> initial) Must be called immediately after Subscriber.onSubscribe(Subscription).

Methods inherited from class java.lang.Object

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

Method Detail

start

public void start(Callable<CompletionStage<? extends P>> initial)

Must be called immediately after Subscriber.onSubscribe(Subscription).

Parameters:

initial - the future that, once complete, will produce the first page.

request

public void request(long n)

Specified by:

request in interface Subscription

cancel

public void cancel()

Specified by:

cancel in interface Subscription

doOnError

public void doOnError(Throwable error)