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 {

import org.opensearch.action.bulk.BulkRequestBuilder;
import org.opensearch.action.bulk.BulkResponse;
import org.opensearch.action.delete.DeleteResponse;
import org.opensearch.action.get.GetResponse;
import org.opensearch.action.index.IndexResponse;
import org.opensearch.action.search.SearchRequestBuilder;
import org.opensearch.action.search.SearchResponse;
import org.opensearch.action.support.WriteRequest.RefreshPolicy;

                return digest;
            }

            @Override
            public CommonServerMessageBlockResponse getResponse() {
                return response;
            }

            @Override
            public void setResponse(CommonServerMessageBlockResponse msg) {
                this.response = msg;
            }

            @Override
            public long getMid() {

	public final fun getHeaders ()Lokhttp3/Headers;
	public final fun getMethod ()Ljava/lang/String;
	public final fun getPath ()Ljava/lang/String;
	public final fun getResponse ()Lmockwebserver3/MockResponse;
}

public class mockwebserver3/QueueDispatcher : mockwebserver3/Dispatcher {
	public fun <init> ()V
	public fun clear ()V
	public fun close ()V

                builder.addKind(SuggestItem.Kind.DOCUMENT.toString());
            }

            final SuggestResponse suggestResponse = builder.execute().getResponse();

            buf.append("\"query_time\":").append(suggestResponse.getTookMs());
            buf.append(",\"record_count\":").append(suggestResponse.getTotal());

     */
    public void completeOperation(final String operationName) {
        try (CurlResponse getResponse = ComponentUtil.getCurlHelper() //
                .get("/" + getIndexName() + "/_doc/" + operationName) //
                .execute()) {
            if (getResponse.getHttpStatusCode() != 200) {
                logger.debug("Operation document not found: operation={}", operationName);

        public SMBSigningDigest getDigest() {
            return this.digest;
        }

        @Override
        public CommonServerMessageBlockResponse getResponse() {
            return this.response;
        }

        @Override
        public void setResponse(CommonServerMessageBlockResponse msg) {
            this.response = msg;
        }

        @Override
        public long getMid() {

            final SearchResult<T, GetRequestBuilder, GetResponse> searchResult) {
        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
        final long startTime = systemHelper.getCurrentTimeAsLong();

        GetResponse response = null;
        final GetRequestBuilder requestBuilder = client.prepareGet(index, id);

        // SPNEGO typically doesn't provide special response handling
        org.lastaflute.web.response.ActionResponse response = authenticator.getResponse(org.codelibs.fess.sso.SsoResponseType.METADATA);
        assertNull(response);

        response = authenticator.getResponse(org.codelibs.fess.sso.SsoResponseType.LOGOUT);
        assertNull(response);
    }

    @Test
    public void test_innerClassNaming() {

                    return null;
                } catch (final IOException se) {
                    if (request != null && request.getResponse() != null) {
                        // tree connect might still have succeeded
                        response = (TreeConnectResponse) request.getResponse();
                        if (response.isReceived() && !response.isError() && response.getErrorCode() == NtStatus.NT_STATUS_SUCCESS) {