/**
   * Returns a new builder, expecting the specified number of entries to be added.
   *
   * <p>If {@code expectedSize} is exactly the number of entries added to the builder before {@link
   * Builder#build} is called, the builder is likely to perform better than an unsized {@link
   * #builder()} would have.
   *
   * <p>It is not specified if any performance benefits apply if {@code expectedSize} is close to,

### Async Context Manager { #async-context-manager }

If you check, the function is decorated with an `@asynccontextmanager`.

That converts the function into something called an "**async context manager**".

{* ../../docs_src/events/tutorial003_py310.py hl[1,13] *}

        // Create an NdrSmall object with a specific value
        NdrSmall ndrSmall = new NdrSmall(100);

        // Call the encode method
        ndrSmall.encode(mockNdrBuffer);

        // Verify that enc_ndr_small was called with the correct value
        verify(mockNdrBuffer, times(1)).enc_ndr_small(100);
        verifyNoMoreInteractions(mockNdrBuffer);
    }

    @Test
    void testDecode() throws NdrException {

     * existing values in the execution request that are controlled by the toolchains. Hence, it is expected that this
     * method is called on a new/empty execution request before the caller mutates it to fit its needs.
     *
     * @param request The execution request to populate, must not be {@code null}.

 *
 * <p>{@code CharSink} provides two kinds of methods:
 *
 * <ul>
 *   <li><b>Methods that return a writer:</b> These methods should return a <i>new</i>, independent
 *       instance each time they are called. The caller is responsible for ensuring that the
 *       returned writer is closed.
 *   <li><b>Convenience methods:</b> These are implementations of common operations that are

 *
 * <p>The service is called during model building for all model objects, allowing
 * implementations to decide which objects to process and how to optimize them.</p>
 *
 * @since 4.0.0
 */
public interface ModelObjectProcessor {

    /**
     * Process a model object, potentially returning a pooled or optimized version.
     *
     * <p>This method is called during model building for various model objects.

        HttpServletRequest request = createMockRequest();
        HttpServletResponse response = createMockResponse();

        corsHandler.process(null, request, response);

        assertTrue("process should be called", processCalled);
        assertNull(processOrigin, "origin should be null");
        assertEquals(request, processRequest);
        assertEquals(response, processResponse);
    }

        assertEquals("file2.txt", second.getName());

        assertFalse(iterator.hasNext(), "Should not have more elements");

        // Verify filter was called for each element
        verify(mockFilter, times(2)).accept(any(SmbResource.class));
    }

    /**
     * Test iterator with filter that rejects all elements.
     */
    @Test

    listener = new MockFutureListener(resultFuture);
  }

  public void testFutureGetBeforeCallback() throws Exception {
    // Verify that get throws a timeout exception before the callback is called.
    assertThrows(TimeoutException.class, () -> resultFuture.get(1L, MILLISECONDS));
  }

  public void testFutureGetThrowsWrappedException() throws Exception {
    inputFuture.setException(EXCEPTION);

 * It also uses an AtomicBoolean to track whether the thread is running.
 * </p>
 *
 * <p>
 * The expired method is called when a timeout occurs.
 * It interrupts the running thread up to a maximum number of times.
 * The stop method is called to stop the timeout target.
 * </p>
 */
public class AccessTimeoutTarget implements TimeoutTarget {