verify(tree).send(captor.capture(), any());
        assertNotNull(captor.getValue());
    }

    @Test
    @DisplayName("recv delegates to input.readDirect and returns its value")
    void testRecvDelegation() throws Exception {
        SmbPipeHandleImpl spyTarget = spy(target);
        SmbPipeInputStream in = mock(SmbPipeInputStream.class);

import java.io.InvalidObjectException;
import java.io.ObjectInputStream;
import java.io.Serializable;
import org.jspecify.annotations.Nullable;

/**
 * List returned by {@link ImmutableCollection#asList} that delegates {@code contains} checks to the
 * backing collection.
 *
 * @author Jared Levy
 * @author Louis Wasserman
 */
@GwtCompatible
@SuppressWarnings("serial")

import jakarta.servlet.http.HttpServletRequest;

@ExtendWith(MockitoExtension.class)
public class NtlmHttpServletRequestTest {

    @Test
    @DisplayName("constructor stores principal and delegates properly")
    void testHappyPath(@Mock HttpServletRequest mockRequest, @Mock Principal mockPrincipal) {
        when(mockPrincipal.getName()).thenReturn("user1");

    } else if (superString != null) {
      return resultString + superString;
    }
    return null;
  }

  /**
   * An {@link AbstractTransformFuture} that delegates to an {@link AsyncFunction} and {@link
   * #setFuture(ListenableFuture)}.
   */
  private static final class AsyncTransformFuture<
          I extends @Nullable Object, O extends @Nullable Object>

import org.junit.jupiter.params.provider.ValueSource;
import org.mockito.junit.jupiter.MockitoExtension;

/**
 * Unit tests for {@link NdrHyper}.
 * <p>
 * The class only contains an encode/decode pair that delegates to
 * {@link NdrBuffer#enc_ndr_hyper(long)} and {@link NdrBuffer#dec_ndr_hyper()}.
 * The tests verify that:
 * <ul>
 *   <li>encoding and decoding round‑trip correctly handle typical, zero,

        // expired() with empty buffer is no-op (no exception)
        logNotificationTarget.expired();
    }

    @Test
    public void test_flush_callsExpired() {
        // flush() delegates to expired(); with empty buffer, no-op (no exception)
        logNotificationTarget.flush();
    }

    @Test
    public void test_expired_withEvents_drainsBuffer() {
        // Add events to buffer

        processor.completed("rootId", rootCompleteEvent)

        then:
        1 * delegate.started(rootDescriptor, rootTestStartEvent)
        1 * delegate.started(testDescriptor1, testStartEvent1)
        1 * delegate.started(testDescriptor2, testStartEvent2)
        1 * delegate.failure("testId2", testError2)
        0 * delegate.completed("rootId", rootCompleteEvent)

        when:

import okhttp3.internal.delimiterOffset
import okhttp3.internal.platform.Platform
import okhttp3.internal.platform.Platform.Companion.WARN
import okhttp3.internal.trimSubstring

/** A cookie jar that delegates to a [java.net.CookieHandler]. */
class JavaNetCookieJar(
  private val cookieHandler: CookieHandler,
) : CookieJar {
  override fun saveFromResponse(
    url: HttpUrl,
    cookies: List<Cookie>,
  ) {

import org.apache.maven.model.Profile;
import org.apache.maven.model.resolution.ModelResolver;
import org.apache.maven.model.resolution.WorkspaceModelResolver;

/**
 * A model building request that delegates all methods invocations to another request, meant for easy transformations by
 * subclassing.
 *
 * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead
 */
@Deprecated(since = "4.0.0")

            }
        };

        // When/Then
        assertThrows(CIFSException.class, () -> iterator.close(), "Should propagate exception from delegate close");
    }

    /**
     * Test remove method delegates to underlying iterator.
     */
    @Test
    void testRemove() {
        // Given
        when(mockDelegate.hasNext()).thenReturn(true, false);