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

Class ReadResultSubscription

java.lang.Object

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

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

All Implemented Interfaces:

Subscription

public class ReadResultSubscription
extends ResultSubscription<ReadResult,AsyncResultSet>

Constructor Summary

Constructors

Constructor and Description
ReadResultSubscription(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

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

cancel, doOnError, request, start

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadResultSubscription

public ReadResultSubscription(@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)