final NdrBuffer nb = new NdrBuffer(this.buf, this.start);
        nb.index = idx;
        nb.deferred = this.deferred;
        return nb;
    }

    /**
     * Resets the buffer position to the start.
     */
    public void reset() {
        this.index = this.start;
        this.length = 0;
        this.deferred = this;
    }

    /**
     * Returns the current index position in the buffer.
     *

                _dst = _dst.deferred;
                this.root_directory.encode(_dst);

            }
            if (this.object_name != null) {
                _dst = _dst.deferred;
                this.object_name.encode(_dst);

            }
            if (this.security_quality_of_service != null) {
                _dst = _dst.deferred;

 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.suggest.request;

import org.codelibs.fess.suggest.concurrent.Deferred;
import org.opensearch.transport.client.Client;

/**
 * An abstract class that serves as a builder for creating and executing requests.
 *
 * @param <Req> the type of the request

    @Mock
    private NdrBuffer mockDeferredBuffer;

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        // Set the deferred field directly since it's a public field, not a method
        mockNdrBuffer.deferred = mockDeferredBuffer;
        lenient().when(mockNdrBuffer.derive(anyInt())).thenReturn(mockDeferredBuffer);

            // Create a real NdrBuffer mock that can handle the deferred field access
            // But only test the non-deferred parts to avoid field mocking issues

            // When: Trying to encode (may throw exception due to deferred buffer)
            // Then: Should at least call the basic encoding methods before hitting deferred
            assertThrows(Exception.class, () -> {

        assertEquals(0, derivedBuffer.start); // Derived buffer starts from the original buffer's start
        assertEquals(10, derivedBuffer.index);
        assertSame(ndrBuffer.deferred, derivedBuffer.deferred); // Deferred should be the same as original

        // Ensure changes to derived buffer don't affect original's index/start
        derivedBuffer.advance(5);
        assertEquals(15, derivedBuffer.index);

     */
    public Deferred<SuggestIndexResponse>.Promise indexFromQueryLog(final QueryLogReader queryLogReader, final int docPerReq,
            final long requestInterval) {
        final Deferred<SuggestIndexResponse> deferred = new Deferred<>();
        threadPool.execute(() -> {
            final long start = System.currentTimeMillis();

                    deferred.reject(new SuggesterException("Search failure. Failed shards num:" + searchResponse.getFailedShards()));
                } else {
                    deferred.resolve(createResponse(searchResponse));
                }
            }

            @Override
            public void onFailure(final Exception e) {
                deferred.reject(new SuggesterException(e.getMessage(), e));

    @Mock
    private rpc.unicode_string mockUnicodeString;

    @Mock
    private lsarpc.LsarSidArray mockLsarSidArray;

    @BeforeEach
    void setUp() {
        // Directly set the deferred field on the mock
        mockNdrBuffer.deferred = mockDeferredBuffer;

        // Configure mocks for NdrBuffer interactions
        lenient().when(mockDeferredBuffer.derive(anyInt())).thenReturn(mockDeferredBuffer);

            return mimeTypeHelper.getContentType(is, filename);
        }
    }

    /**
     * Gets an input stream for the content in the deferred file output stream.
     *
     * @param out the deferred file output stream
     * @return the input stream for the content
     * @throws IOException if an I/O error occurs
     */