*   <li>Each other step is derived from one or more input steps. At each step, zero or more objects
 *       can be captured for later closing.
 *   <li>There is one last step (the root of the tree), from which you can extract the final result
 *       of the computation. After that result is available (or the computation fails), all objects
 *       captured by any of the steps in the pipeline are closed.
 * </ol>
 *
 * <h3>Starting a pipeline</h3>
 *

        DataStoreParams captured = capturedParams.get();
        assertNotNull(captured);
        assertEquals("test-value", captured.getAsString("string"));
        assertEquals(42, captured.get("integer"));
        assertEquals(123456789L, captured.get("long"));
        assertEquals(true, captured.get("boolean"));
        assertEquals(3.14, captured.get("double"));
        assertNotNull(captured.get("map"));

        assertNull(ex.getRootCause(), "Root cause should be null by default");
        assertTrue(ex instanceof SmbException, "Should be an SmbException subtype");
    }

    /**
     * Ensures the exception is thrown and captured via assertThrows with the right message.
     */
    @Test
    void assertThrowsCapturesExceptionAndMessage() {
        // Act & Assert
        SmbEndOfFileException thrown = assertThrows(SmbEndOfFileException.class, () -> {

    When a dependency with yield raises after the yield (not in an except), the
    response is already "successfully" sent back to the client, but there's still
    an error in the server afterwards, an exception is raised and captured or shown
    in the server logs.
    """
    with TestClient(app, raise_server_exceptions=False) as client:
        response = client.get("/broken")
        assert response.status_code == 200

                    throw new CrawlerSystemException(e);
                }
            }
        }

        /**
         * Gets the captured output as a single string.
         * @return The captured output with newlines.
         */
        public String getOutput() {
            final StringBuilder buf = new StringBuilder(100);
            for (final String value : list) {

            // Give the writer thread time to process and set exception
            w.wait(100);
        }

        // Wait a bit more to ensure exception is captured
        Thread.sleep(100);

        // Act + Assert: checkException should throw the SmbException captured by the thread
        assertThrows(SmbException.class, w::checkException);

        // Stop the thread
        synchronized (w) {

            RecordingFilter filter = new RecordingFilter();
            filter.accept(mockFile);
            // Verify the filter stored the reference
            // assertSame may not be necessary but demonstrates captured file
            // we simply check that getPath was called
            verify(mockFile, times(1)).getPath();
        }
    }

    assertAssignable(
        TypeToken.of(new TypeCapture<L>() {}.capture()),
        TypeToken.of(new TypeCapture<L>() {}.capture()));
    assertNotAssignable(
        TypeToken.of(new TypeCapture<R>() {}.capture()),
        TypeToken.of(new TypeCapture<L>() {}.capture()));
    assertAssignable(TypeToken.of(new TypeCapture<L>() {}.capture()), new TypeToken<List<R>>() {});
  }

  public void testisSupertypeOf_resolved() {

        assertTrue(exception instanceof Exception);
        assertTrue(exception instanceof Throwable);
    }

    @Test
    public void test_stackTrace() {
        // Test that stack trace is properly captured
        final JobProcessingException exception = new JobProcessingException("Stack trace test");

        assertNotNull(exception.getStackTrace());
        assertTrue(exception.getStackTrace().length > 0);

        while ((event = queue.poll()) != null) {
            events.add(event);
            size.decrementAndGet();
        }
        return events;
    }

    /**
     * Represents a captured log event for notification.
     */
    public static class LogNotificationEvent {

        private final long timestamp;

        private final String level;

        private final String loggerName;