sourcePos += bytesToRead
        return bytesToRead
      }

      // Read from upstream. This always reads a full buffer: that might be more than what the
      // current call to Source.read() has requested.
      try {
        val upstreamBytesRead = upstream!!.read(upstreamBuffer, bufferMaxSize)

        // If we've exhausted upstream, we're done.
        if (upstreamBytesRead == -1L) {
          commit(upstreamPos)

import org.lastaflute.web.Execute;
import org.lastaflute.web.response.ActionResponse;
import org.lastaflute.web.response.StreamResponse;

/**
 * Action class for handling cached document content requests.
 * Provides functionality to retrieve and display cached versions of crawled documents.
 */
public class CacheAction extends FessSearchAction {

    /**
     * Creates a new instance of CacheAction.
     */

    void testSequentialOperations() {
        // Given
        request.setNotifyFlags(0);
        request.setCompletionFilter(0);

        // When - first write
        byte[] buffer1 = new byte[512];
        request.writeBytesWireFormat(buffer1, 0);

        // Update values
        request.setNotifyFlags(Smb2ChangeNotifyRequest.SMB2_WATCH_TREE);
        request.setCompletionFilter(0xFFF);

        // Second write

        "upgrade".equals(request.header("Connection"), ignoreCase = true)
    try {
      exchange.writeRequestHeaders(request)

      if (hasRequestBody) {
        // If there's a "Expect: 100-continue" header on the request, wait for a "HTTP/1.1 100
        // Continue" response before transmitting the request body. If we don't get that, return
        // what we did get (such as a 4xx response) without ever transmitting the request body.

        super(client, new SuggestRequest());
        request.setReadingConverter(readingConverter);
        request.setNormalizer(normalizer);
    }

    /**
     * Sets the index for the request.
     * @param index The index name.
     * @return This builder instance.
     */
    public SuggestRequestBuilder setIndex(final String index) {
        request.setIndex(index);
        return this;
    }

    /**

        assertTrue(request.isHiraganaQuery("けんさく"));
        assertTrue(request.isHiraganaQuery("あいうえおかきくけこさしすせそたちつてとなにぬねのはひふへほまみむめもやゆよをわん"));
        assertTrue(request.isHiraganaQuery("がぎぐげござじずぜぞだぢづでどばびぶべぼ"));
        assertTrue(request.isHiraganaQuery("ぁぃぅぇぉっゃゅょ"));

        assertFalse(request.isHiraganaQuery("こ犬"));
        assertFalse(request.isHiraganaQuery("abc"));
        assertFalse(request.isHiraganaQuery("カキク"));

        MockletHttpServletRequest request = getMockRequest();
        request.setParameter("geo.location.1.point", "34,150");
        request.setParameter("geo.location.1.distance", "10km");
        request.setParameter("geo.location.2.point", "35,151");
        request.setParameter("geo.location.2.distance", "1km");

        final GeoInfo geoInfo = new GeoInfo(request);
        String result =

     */
    int size();

    /**
     * Creates a cancel request for this request.
     *
     * @return create cancel request
     */
    CommonServerMessageBlockRequest createCancel();

    /**
     * Checks if chaining is allowed with the next request.
     *
     * @param next the next request in the chain
     * @return whether to allow chaining
     */

	// sets the bucket policy using the policy statement generated from `getReadOnlyBucketStatement` so that the
	// unsigned request goes through and its validated again.
	ExecObjectLayerAPIAnonTest(t, obj, "TestGetBucketLocationHandler", bucketName, "", instanceType, apiRouter, anonReq, getAnonReadOnlyBucketPolicy(bucketName))

	// HTTP request for testing when `objectLayer` is set to `nil`.

    Response response = client.newCall(request).execute();
    response.body().close();
  }

  private static class LoggingInterceptor implements Interceptor {
    @Override public Response intercept(Chain chain) throws IOException {
      long t1 = System.nanoTime();
      Request request = chain.request();
      logger.info(String.format("Sending request %s on %s%n%s",
          request.url(), chain.connection(), request.headers()));