|
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