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

Class ContinuousReadResultSubscription

java.lang.Object

com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription<ReadResult,ContinuousAsyncResultSet>

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

All Implemented Interfaces:

Subscription

public class ContinuousReadResultSubscription
extends ResultSubscription<ReadResult,ContinuousAsyncResultSet>

Constructor Summary

Constructors

Constructor and Description
ContinuousReadResultSubscription(Subscriber<? super ReadResult> subscriber, Statement<?> statement, ExecutionListener listener, Semaphore maxConcurrentRequests, com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter, boolean failFast)

Method Summary

Modifier and Type	Method and Description
void	cancel()
protected ReadResult	toErrorResult(BulkExecutionException error) Creates a result from the given error.

Methods inherited from class com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription

doOnError, request, start

Methods inherited from class java.lang.Object

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

Constructor Detail

ContinuousReadResultSubscription

public ContinuousReadResultSubscription(@NonNull
                                        Subscriber<? super ReadResult> subscriber,
                                        @NonNull
                                        Statement<?> statement,
                                        @Nullable
                                        ExecutionListener listener,
                                        @Nullable
                                        Semaphore maxConcurrentRequests,
                                        @Nullable
                                        com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter,
                                        boolean failFast)

Method Detail

cancel

public void cancel()

Specified by:

cancel in interface Subscription

Overrides:

cancel in class ResultSubscription<ReadResult,ContinuousAsyncResultSet>

toErrorResult

protected ReadResult toErrorResult(BulkExecutionException error)

Description copied from class: ResultSubscription

Creates a result from the given error.

Parameters:

error - The error to convert.

Returns:

the error result.