assertThrows(ExecutionException.class, () -> {
            future.get();
        });

        verify(mockManager).completeReconnect("/test/file.txt", false);
    }

    @Test
    public void testReconnectHandleNoHandle() throws Exception {
        when(mockManager.getHandleForReconnect("/test/file.txt")).thenReturn(null);