Skip to content

Commit 92b7915

Browse files
author
Alexandre Dutra
committed
Use GuavaCompatibility instead of Guava deprecated methods
1 parent a13c5d5 commit 92b7915

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

driver-mapping/src/test/java/com/datastax/driver/mapping/MapperAsyncResultTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
package com.datastax.driver.mapping;
1717

1818
import com.datastax.driver.core.CCMTestsSupport;
19+
import com.datastax.driver.core.GuavaCompatibility;
1920
import com.datastax.driver.core.SimpleStatement;
2021
import com.datastax.driver.core.Statement;
2122
import com.datastax.driver.core.utils.CassandraVersion;
@@ -94,7 +95,7 @@ private void should_iterate_result_set_asynchronously(int totalCount, int fetchS
9495
Mapper<User> mapper = new MappingManager(session()).mapper(User.class);
9596
ResultsAccumulator accumulator = new ResultsAccumulator();
9697
ListenableFuture<Result<User>> results = mapper.mapAsync(session().executeAsync(statement));
97-
ListenableFuture<Result<User>> future = Futures.transform(
98+
ListenableFuture<Result<User>> future = GuavaCompatibility.INSTANCE.transformAsync(
9899
results,
99100
accumulator);
100101
Futures.getUnchecked(future);
@@ -120,7 +121,7 @@ public ListenableFuture<Result<User>> apply(Result<User> users) throws Exception
120121
if (wasLastPage)
121122
return Futures.immediateFuture(users);
122123
else
123-
return Futures.transform(users.fetchMoreResults(), this);
124+
return GuavaCompatibility.INSTANCE.transformAsync(users.fetchMoreResults(), this);
124125
}
125126
}
126127
}

0 commit comments

Comments
 (0)