public class ContinuousReadResultPublisher extends Object implements Publisher<ReadResult>
Publisher for ReadResults that uses continuous paging.| Constructor and Description |
|---|
ContinuousReadResultPublisher(Statement<?> statement,
ContinuousSession session,
boolean failFast)
Creates a new
ContinuousReadResultPublisher with default paging options, without ExecutionListener and without throughput regulation. |
ContinuousReadResultPublisher(Statement<?> statement,
ContinuousSession session,
boolean failFast,
ExecutionListener listener,
Semaphore maxConcurrentRequests,
com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter)
Creates a new
ContinuousReadResultPublisher. |
| Modifier and Type | Method and Description |
|---|---|
void |
subscribe(Subscriber<? super ReadResult> subscriber) |
public ContinuousReadResultPublisher(@NonNull
Statement<?> statement,
@NonNull
ContinuousSession session,
boolean failFast)
ContinuousReadResultPublisher with default paging options, without ExecutionListener and without throughput regulation.statement - The Statement to execute.session - The ContinuousSession to use.failFast - whether to fail-fast in case of error.public ContinuousReadResultPublisher(@NonNull
Statement<?> statement,
@NonNull
ContinuousSession session,
boolean failFast,
@Nullable
ExecutionListener listener,
@Nullable
Semaphore maxConcurrentRequests,
@Nullable
com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter)
ContinuousReadResultPublisher.statement - The Statement to execute.session - The ContinuousSession 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.public void subscribe(Subscriber<? super ReadResult> subscriber)
subscribe in interface Publisher<ReadResult>Copyright © 2017–2021 DataStax. All rights reserved.