com.datastax.oss.dsbulk.executor.api.publisher

Class ReadResultPublisher

java.lang.Object

com.datastax.oss.dsbulk.executor.api.publisher.ReadResultPublisher

All Implemented Interfaces:

Publisher<ReadResult>

public class ReadResultPublisher
extends Object
implements Publisher<ReadResult>

A Publisher for ReadResults.

See Also:

ReactiveBulkReader.readReactive(Statement)

Constructor Summary

Constructors

Constructor and Description
ReadResultPublisher(Statement<?> statement, CqlSession session, boolean failFast) Creates a new ReadResultPublisher without ExecutionListener and without throughput regulation.
ReadResultPublisher(Statement<?> statement, CqlSession session, boolean failFast, ExecutionListener listener, Semaphore maxConcurrentRequests, com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter) Creates a new ReadResultPublisher.

Method Summary

Modifier and Type	Method and Description
void	subscribe(Subscriber<? super ReadResult> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadResultPublisher

public ReadResultPublisher(@NonNull
                           Statement<?> statement,
                           @NonNull
                           CqlSession session,
                           boolean failFast)

Creates a new ReadResultPublisher without ExecutionListener and without throughput regulation.

Parameters:

statement - The Statement to execute.

session - The CqlSession to use.

failFast - whether to fail-fast in case of error.

ReadResultPublisher

public ReadResultPublisher(@NonNull
                           Statement<?> statement,
                           @NonNull
                           CqlSession session,
                           boolean failFast,
                           @Nullable
                           ExecutionListener listener,
                           @Nullable
                           Semaphore maxConcurrentRequests,
                           @Nullable
                           com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter)

Creates a new ReadResultPublisher.

Parameters:

statement - The Statement to execute.

session - The CqlSession to use.

failFast - whether to fail-fast in case of error.

listener - The ExecutionListener to use.

maxConcurrentRequests - The Semaphore to use to regulate the amount of in-flight requests.

rateLimiter - The RateLimiter to use to regulate throughput.

Method Detail

subscribe

public void subscribe(Subscriber<? super ReadResult> subscriber)

Specified by:

subscribe in interface Publisher<ReadResult>