assertThat(getResponse(methodName).getResult()).isNull();
  }

  /**
   * Asserts that a prior call that had caused this thread to block or wait has since returned the
   * expected boolean value.
   */
  public void assertPriorCallReturns(boolean expected, @Nullable String methodName)
      throws Exception {
    assertEquals(expected, getResponse(methodName).getResult());
  }

  /**

        assertNotNull(result);
        assertFalse(result.hasFailure());

        runner.refresh();

        GetResponse getResponse =
                runner.client().prepareGet().setIndex(suggester.getIndex()).setId(item.getId()).get(TimeValue.timeValueSeconds(30));
        assertTrue(getResponse.isExists());
    }

    @Test
    public void test_writeItemsWithUpdate() throws Exception {

     */
    public Object get(final String key) {
        final GetResponse getResponse =
                client.prepareGet().setIndex(settingsIndexName).setId(settingsId).execute().actionGet(getSearchTimeout());
        if (!getResponse.isExists()) {
            return null;
        }
        final Map<String, Object> map = getResponse.getSource();
        return map.get(key);
    }

    assertThat(getResponse(methodName).getResult()).isNull();
  }

  /**
   * Asserts that a prior call that had caused this thread to block or wait has since returned the
   * expected boolean value.
   */
  public void assertPriorCallReturns(boolean expected, @Nullable String methodName)
      throws Exception {
    assertEquals(expected, getResponse(methodName).getResult());
  }

  /**

        assertNotNull(authenticator.getLastResolver());
    }

    // Test getResponse method with different response types
    @Test
    public void test_getResponse_withMetadataType() {
        // Setup - Test with null response initially
        ActionResponse result = authenticator.getResponse(SsoResponseType.METADATA);

        // Verify initial state
        assertNull(result);

        assertEquals("testuser", ((TestLoginCredential) credential).username);
    }

    // Test getResponse() method
    @Test
    public void test_getResponse_whenNotAvailable() {
        currentSsoType = Constants.NONE;
        assertNull(ssoManager.getResponse(SsoResponseType.METADATA));
        assertNull(ssoManager.getResponse(SsoResponseType.LOGOUT));
    }

    @Test

        assertNotNull(processor);
        assertNotNull(processor.getResponse());
    }

    @Test
    public void testRequestProcessorGetResponse() {
        // Test RequestProcessor getResponse method
        CurlRequest.RequestProcessor processor = new CurlRequest.RequestProcessor("UTF-8", 2048);
        CurlResponse response = processor.getResponse();
        assertNotNull(response);
    }

    @Test

    @Test
    public void test_completeOperation_ownInstance_deletesDoc() {
        setupMockFessConfig();
        final String getResponse = "{\"found\":true,\"_seq_no\":5,\"_primary_term\":1,"
                + "\"_source\":{\"type\":\"operation\",\"name\":\"reindex\"," + "\"instanceId\":\"node1@host1\",\"status\":\"running\"}}";

        connect(con -> {
            final RequestProcessor processor = new RequestProcessor(encoding, threshold);
            processor.accept(con);
            try (final CurlResponse res = processor.getResponse()) {
                actionListener.accept(res);
            } catch (final IOException e) {
                exceptionListener.accept(e);
            }
        }, exceptionListener);
    }

    /**

            if (logger.isDebugEnabled()) {
                logger.debug("Logging in with SPNEGO Authenticator");
            }
            final HttpServletResponse response = LaResponseUtil.getResponse();
            final SpnegoHttpServletResponse spnegoResponse = new SpnegoHttpServletResponse(response);

            // client/caller principal
            final SpnegoPrincipal principal;
            try {