|
24 | 24 | import static org.junit.Assert.assertFalse; |
25 | 25 | import static org.junit.jupiter.api.Assertions.assertThrows; |
26 | 26 | import static org.mockito.ArgumentMatchers.any; |
27 | | -import static org.mockito.BDDMockito.given; |
28 | | -import static org.mockito.BDDMockito.then; |
29 | 27 | import static org.mockito.Mockito.mock; |
30 | 28 | import static org.mockito.Mockito.verify; |
31 | 29 | import static org.mockito.Mockito.when; |
|
40 | 38 | import static org.neo4j.driver.testutil.TestUtil.verifyRollbackTx; |
41 | 39 | import static org.neo4j.driver.testutil.TestUtil.verifyRunAndPull; |
42 | 40 |
|
43 | | -import java.util.concurrent.CompletableFuture; |
44 | 41 | import java.util.function.Consumer; |
45 | 42 | import java.util.function.Function; |
46 | 43 | import java.util.stream.Stream; |
|
53 | 50 | import org.neo4j.driver.Transaction; |
54 | 51 | import org.neo4j.driver.Value; |
55 | 52 | import org.neo4j.driver.internal.async.ConnectionContext; |
56 | | -import org.neo4j.driver.internal.async.UnmanagedTransaction; |
57 | 53 | import org.neo4j.driver.internal.messaging.v4.BoltProtocolV4; |
58 | 54 | import org.neo4j.driver.internal.spi.Connection; |
59 | 55 | import org.neo4j.driver.internal.spi.ConnectionProvider; |
@@ -154,17 +150,6 @@ void shouldReleaseConnectionWhenFailedToClose() { |
154 | 150 | shouldReleaseConnectionWhenFailedToAction(Transaction::close); |
155 | 151 | } |
156 | 152 |
|
157 | | - @Test |
158 | | - void shouldDelegateInterrupt() { |
159 | | - var unmanagedTx = mock(UnmanagedTransaction.class); |
160 | | - given(unmanagedTx.interruptAsync()).willReturn(CompletableFuture.completedFuture(null)); |
161 | | - var tx = new InternalTransaction(unmanagedTx); |
162 | | - |
163 | | - tx.interrupt(); |
164 | | - |
165 | | - then(unmanagedTx).should().interruptAsync(); |
166 | | - } |
167 | | - |
168 | 153 | private void shouldReleaseConnectionWhenFailedToAction(Consumer<Transaction> txAction) { |
169 | 154 | setupFailingRollback(connection); |
170 | 155 | assertThrows(Exception.class, () -> txAction.accept(tx)); |
|
0 commit comments