Skip to content

Commit

Permalink
Remove ListenableFuture support.
Browse files Browse the repository at this point in the history
Closes #1548
  • Loading branch information
mp911de committed Jan 14, 2025
1 parent 1dac7aa commit 5dc484e
Show file tree
Hide file tree
Showing 28 changed files with 9 additions and 6,794 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@
import java.util.stream.Collector;

import org.springframework.util.Assert;
import org.springframework.util.concurrent.ListenableFuture;

import com.datastax.oss.driver.api.core.cql.AsyncResultSet;
import com.datastax.oss.driver.api.core.cql.Row;
Expand Down Expand Up @@ -75,7 +74,7 @@ <R> AsyncResultStream<R> map(RowMapper<R> mapper) {

/**
* Performs a mutable reduction operation on the elements of this stream using a {@link Collector} resulting in a
* {@link ListenableFuture}.
* {@link CompletableFuture}.
* <p>
* This is a terminal operation.
*
Expand All @@ -97,7 +96,7 @@ <R, A> CompletableFuture<R> collect(Collector<? super T, A, R> collector) {
}

/**
* Performs an action for each element of this stream. This method returns a {@link ListenableFuture} that completes
* Performs an action for each element of this stream. This method returns a {@link CompletableFuture} that completes
* without a value ({@code null}) once all elements have been processed.
* <p>
* This is a terminal operation.
Expand Down Expand Up @@ -177,7 +176,7 @@ void forEachAsync(CompletableFuture<Void> target, AsyncResultSet resultSet) {
class CollectState<A, R> {

private final AtomicInteger rowNumber = new AtomicInteger();
private volatile A intermediate;
private final A intermediate;
private final Collector<? super T, A, R> collector;

CollectState(Collector<? super T, A, R> collector) {
Expand Down

This file was deleted.

Loading

0 comments on commit 5dc484e

Please sign in to comment.