From e01c8b91c85896da906d69f1fdc604fa7df66d94 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Tue, 24 Jul 2018 12:08:19 +0200 Subject: [PATCH] DATACASS-581 - Fix test conditions in DefaultBridgedReactiveSessionUnitTests. Report completed future to adapt to Guava's future state checking in newer library versions. --- .../core/cql/DefaultBridgedReactiveSessionUnitTests.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/DefaultBridgedReactiveSessionUnitTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/DefaultBridgedReactiveSessionUnitTests.java index 106e0fca0..39246736d 100644 --- a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/DefaultBridgedReactiveSessionUnitTests.java +++ b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/DefaultBridgedReactiveSessionUnitTests.java @@ -52,7 +52,7 @@ import com.google.common.util.concurrent.ListenableFuture; * * @author Mark Paluch */ -@RunWith(MockitoJUnitRunner.class) +@RunWith(MockitoJUnitRunner.Silent.class) public class DefaultBridgedReactiveSessionUnitTests { @Mock Session sessionMock; @@ -77,6 +77,8 @@ public class DefaultBridgedReactiveSessionUnitTests { return null; }).when(future).addListener(any(), any()); + + when(future.isDone()).thenReturn(true); } @Test // DATACASS-335 @@ -248,6 +250,7 @@ public class DefaultBridgedReactiveSessionUnitTests { return null; }).when(future).addListener(any(), any()); + when(future.isDone()).thenReturn(true); when(future.get()).thenReturn(resultSet); when(resultSet.isFullyFetched()).thenReturn(false, false, true); when(resultSet.fetchMoreResults()).thenReturn(future);