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

Class WriteResultSubscription

java.lang.Object

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

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

All Implemented Interfaces:

Subscription

public class WriteResultSubscription
extends ResultSubscription<WriteResult,AsyncResultSet>

Constructor Summary

Constructors

Constructor and Description
WriteResultSubscription(Subscriber<? super WriteResult> 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

WriteResultSubscription

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