}

  public void testCheckPositive_maxLong() {
    MathPreconditions.checkPositive("long", Long.MAX_VALUE);
  }

  public void testCheckPositive_minLong() {
    assertThrows(
        IllegalArgumentException.class,
        () -> MathPreconditions.checkPositive("long", Long.MIN_VALUE));
  }

  public void testCheckPositive_positiveLong() {
    MathPreconditions.checkPositive("long", 1);
  }

  @CollectionSize.Require(absent = ZERO)
  public void testGetOrDefault_present() {
    assertEquals(
        "getOrDefault(present, def) should return the associated value",
        v0(),
        getMap().getOrDefault(k0(), v3()));
  }

  @CollectionSize.Require(absent = ZERO)
  public void testGetOrDefault_presentNullDefault() {
    assertEquals(

  public void testSingleTearDown() throws Exception {
    TearDownStack stack = buildTearDownStack();

    SimpleTearDown tearDown = new SimpleTearDown();
    stack.addTearDown(tearDown);

    assertEquals(false, tearDown.ran);

    stack.runTearDown();

    assertEquals("tearDown should have run", true, tearDown.ran);
  }

  public void testMultipleTearDownsHappenInOrder() throws Exception {

    @Before
    public void setUp() {
        fesenClient = new FesenClient();
        mockClient = mock(Client.class);
        fesenClient.client = mockClient;
    }

    /**
     * Test: Thread-safe listener management using CopyOnWriteArrayList
     * Verifies that multiple threads can safely add listeners concurrently
     */
    @Test
    public void testThreadSafeListenerManagement() throws Exception {

            @Override
            public void run(MojoExecution mojoExecution) throws LifecycleExecutionException {
                MojoExecutor.this.execute(session, mojoExecution, dependencyContext, phaseRecorder);
            }
        });
    }

    private void execute(
            MavenSession session,
            MojoExecution mojoExecution,

     */
    public void setResponseBody(final byte[] responseBody) {
        responseBodyBytes = responseBody;
    }

    /**
     * Sets the response body from a file.
     *
     * @param responseBody the file containing the response body
     * @param isTemporary true if the file is temporary and should be deleted when closing
     */

    void getSessionReturnsUnderlying() {
        // Verifies getSession() exposes the session provided by the connection
        assertSame(session, handle.getSession());
        verify(treeConnection).getSession();
    }

    @Test
    @DisplayName("ensureDFSResolved forwards to tree connection with locator")
    void ensureDFSResolvedDelegates() throws Exception {

    @BeforeEach
    void setUp() {
        mockNotifications = new ArrayList<>();
        mockNotifications.add(fileNotifyInfo1);
        mockNotifications.add(fileNotifyInfo2);
        mockNotifications.add(fileNotifyInfo3);
    }

    /**
     * Test watch() method returning notifications
     */
    @Test
    void testWatch() throws CIFSException {
        // Setup mock behavior

   * @since 11.0
   */
  @Override
  public void put(K key, V value) {
    throw new UnsupportedOperationException();
  }

  /**
   * @since 12.0
   */
  @Override
  public void putAll(Map<? extends K, ? extends V> m) {
    for (Entry<? extends K, ? extends V> entry : m.entrySet()) {
      put(entry.getKey(), entry.getValue());
    }
  }

  @Override
  public void cleanUp() {}

  @Override

     * @param id the unique identifier to set
     */
    void setId(IDTYPE id);

    /**
     * Retrieves the session ID associated with this URL queue.
     *
     * @return the session ID as a String.
     */
    String getSessionId();

    /**
     * Sets the session ID for the URL queue.
     *
     * @param sessionId the session ID to set
     */
    void setSessionId(String sessionId);

    /**