* @param query the user's search query string
     * @param context a consumer that allows additional customization of the query context
     * @return a fully constructed QueryContext ready for OpenSearch execution
     */
    public QueryContext build(final SearchRequestType searchRequestType, final String query, final Consumer<QueryContext> context) {
        String q;

## Deployment Concepts { #deployment-concepts }

Here you saw how to use multiple **workers** to **parallelize** the execution of the application, take advantage of **multiple cores** in the CPU, and be able to serve **more requests**.

        assertNotNull(stringRep);
        assertTrue(stringRep.contains("SmbException"));
        assertTrue(stringRep.contains(message));
    }

    @Test
    @DisplayName("Should handle authentication exceptions")
    void testAuthenticationExceptions() {
        // Given
        int ntStatus = NtStatus.NT_STATUS_LOGON_FAILURE;

        // When
        SmbException exception = new SmbException(ntStatus, false);

        assertEquals(message, exception.getMessage());
        assertEquals(complexMessageCode, exception.getMessageCode());
    }

    public void test_causeChainPropagation() {
        // Setup - create a chain of exceptions
        final Exception rootCause = new IllegalArgumentException("Root cause");
        final Exception middleCause = new IllegalStateException("Middle cause", rootCause);
        final String message = "Top level SSO error";

class WebSocketWriterTest {
  private val data = Buffer()
  private val random = Random(0)

  /**
   * Check all data as verified inside of the test. We do this in an AfterEachCallback so that
   * exceptions thrown from the test do not cause this check to fail.
   */
  @RegisterExtension
  val noDataLeftBehind =
    AfterEachCallback { context: ExtensionContext ->

 * <ol>
 *   <li>Initialization: Sets up the crawler context and initializes the URL filter.</li>
 *   <li>Thread Creation: Creates a group of crawler threads to perform the actual crawling.</li>
 *   <li>Execution: Starts the crawler threads and waits for them to complete.</li>
 *   <li>Cleanup: Deletes the crawled data and clears the URL filter.</li>
 * </ol>
 *

     */
    @Override
    protected OptionalThing<LoginManager> myLoginManager() {
        return OptionalThing.empty();
    }

    /**
     * Pre-processes API requests by checking access authorization before executing the action.
     * If access is not allowed, returns an unauthorized error response.
     *
     * @param runtime the action runtime context containing request information

        assertTrue(output.contains("true"));

        // Test close
        logStream.close();
        // After close, the stream should not accept more writes
        // but PrintStream doesn't throw exceptions on write after close
    }

    @Test
    void testConcurrentAccess() throws InterruptedException {
        // Test thread safety of getInstance
        LogStream.setInstance(testStream);

        assertEquals(message, exception.getMessage());
        assertNull(exception.getCause());
    }

    public void test_constructor_withCauseChain() {
        // Test constructor with chained exceptions
        final Exception rootCause = new IllegalArgumentException("Invalid argument");
        final Exception middleCause = new RuntimeException("Runtime error", rootCause);

          URISyntaxException.class);

  @Param Validator validator;
  @Param Result result;
  @Param ExceptionType exceptionType;

  /**
   * The number of other exception types in the cache of known-good exceptions and the number of
   * other {@code ClassValue} entries for the exception type to be tested. This lets us evaluate
   * whether our solution scales to use with multiple exception types and to whether it is affected