builder.value("item1");
                builder.value("item2");
                builder.endArray();
                builder.startObject("nested");
                builder.field("inner", "value");
                builder.endObject();
                builder.endObject();
                return builder;
            }
        };

        try {

      } catch (e: Exception) {
        logger.log(Level.SEVERE, "$this connection from ${raw.inetAddress} crashed", e)
      }
    }
  }

  internal inner class SocketHandler(
    private val connectionIndex: Int,
    private val raw: Socket,
    private val firstExchangePeek: MockResponse,
  ) {
    private var nextExchangeIndex = 0

    @Throws(Exception::class)

    }

    @Test
    @DisplayName("reauthenticate propagates transport failures")
    void testReauthenticatePropagates() throws Exception {
        SmbSessionImpl session = newSession();
        // Cause the inner reauthenticate to fail at first transport call
        when(transport.getNegotiateResponse()).thenThrow(new SmbException("fail"));
        assertThrows(CIFSException.class, session::reauthenticate);
    }

   * smaller). For example, partitioning an iterable containing {@code [a, b, c, d, e]} with a
   * partition size of 3 yields {@code [[a, b, c], [d, e]]} -- an outer iterable containing two
   * inner lists of three and two elements, all in the original order.
   *
   * <p>Iterators returned by the returned iterable do not support the {@link Iterator#remove()}

        for (final String sid : sessionIdList) {
            // remove config
            ComponentUtil.getCrawlingConfigHelper().remove(sid);
        }

    }

    /**
     * Inner thread class for executing data store crawling operations.
     * Each thread handles crawling for a single data configuration,
     * processing documents and updating the search index.
     *

        }
    }

    @Override
    public String toString() {
        return "SynonymFile [path=" + path + ", synonymItemList=" + synonymItemList + ", id=" + id + "]";
    }

    /**
     * An inner class for updating the synonym file.
     * This class handles the process of writing changes to a temporary file
     * and then replacing the original file upon successful commit.
     */

        assertEquals("plugin", artifact.getName());
        assertEquals("", artifact.getVersion());
    }

    // Test inner classes
    public void test_Artifact_constructor() {
        Artifact artifact = new Artifact("test", "1.0.0", "http://test.com/test.jar");
        assertEquals("test", artifact.getName());

      (if (isCanceled()) "canceled " else "") +
        (if (forWebSocket) "web socket" else "call") +
        " to " + redactedUrl()
    )

  internal fun redactedUrl(): String = originalRequest.url.redact()

  inner class AsyncCall(
    private val responseCallback: Callback,
  ) : Runnable {
    @Volatile var callsPerHost = AtomicInteger(0)
      private set

    fun reuseCallsPerHostFrom(other: AsyncCall) {

import jcifs.SmbResourceLocator;

@ExtendWith(MockitoExtension.class)
class SmbEnumerationUtilTest {

    @Mock
    SmbFilenameFilter fnf;

    @Mock
    SmbFileFilter ff;

    // Utility to create a private inner class instance reflectively
    private static Object newPrivateInner(String simpleName, Class<?>[] paramTypes, Object... args) {
        try {
            Class<?> cls = Class.forName("jcifs.smb.SmbEnumerationUtil$" + simpleName);

            }
            return new SpnegoCredential(username[0]);
        }).orElseGet(() -> null);

    }

    /**
     * SPNEGO filter configuration implementation.
     *
     * This inner class provides configuration parameters for the SPNEGO filter,
     * mapping system properties to SPNEGO configuration values. It handles
     * various authentication settings including Kerberos configuration,