HandleInfo result = future.get();
        assertNotNull(result);
        assertEquals(testHandle, result);

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

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

     */
    private CompletableFuture<HandleInfo> attemptReconnect(HandleInfo info, int attempt, Exception originalCause) {
        if (attempt >= maxRetries) {
            handleManager.completeReconnect(info.getPath(), false);
            return CompletableFuture.failedFuture(new IOException(
                    "Failed to reconnect after " + maxRetries + " attempts. " + "Original cause: " + originalCause.getMessage(),

        HandleInfo info = manager.getHandleForReconnect("/test/file.txt");
        assertTrue(info.isReconnecting());

        manager.completeReconnect("/test/file.txt", true);

        info = manager.getHandleByGuid(guid);
        assertNotNull(info);
        assertFalse(info.isReconnecting());
    }

    @Test