assertThat(new FreshValueGenerator().generateFresh(type)).isNull();
  }

  private static void assertValueAndTypeEquals(Object expected, Object actual) {
    assertEquals(expected, actual);
    assertEquals(expected.getClass(), actual.getClass());
  }

        SMBUtil.writeInt4(contextStartOffsetFromHeader, base, offsetFieldPos);
        SMBUtil.writeInt4(ctx.length, base, offsetFieldPos + 4);

        // Assemble full body: base (fixed-size fields only), but actual context bytes sit elsewhere in the full packet
        // Return just the base; caller is responsible for placing ctx at the correct absolute offset.

              public Integer apply(String from) {
                return Integer.valueOf(from);
              }
            });

    List<Integer> actual = newArrayList(result);
    List<Integer> expected = asList(1, 2, 3);
    assertEquals(expected, actual);
    assertCanIterateAgain(result);
    assertThat(result.toString()).isEqualTo("[1, 2, 3]");
  }

  public void testTransform_forEach() {

 *     .method("GET")
 *     .url("https://example.com")
 *     .weight(1.0f)
 *     .build();
 * </pre>
 *
 * <p>The builder is implemented using an inner class {@link RequestDataContext} that handles
 * the actual construction of the RequestData object.</p>
 *
 */
public final class RequestDataBuilder {
    private RequestDataBuilder() {
    }

    /**

import com.google.common.eventbus.EventBus;
import junit.framework.TestCase;
import org.jspecify.annotations.Nullable;

/**
 * Abstract base class for tests that EventBus finds the correct subscribers.
 *
 * <p>The actual tests are distributed among the other classes in this package based on whether they
 * are annotated or abstract in the superclass.
 *
 * <p>This test must be outside the c.g.c.eventbus package to test correctly.
 *

        expectedAll.eachWithIndex{ ObjectNode expected, int i ->
            if(expected != actual.get(i)) {
                println("\nTransformed Test:")
                SequenceWriter sequenceWriter = WRITER.writeValues(System.out)
                for (ObjectNode transformedTest : actual) {
                    sequenceWriter.write(transformedTest)
                }
                sequenceWriter.close()

func (r *RequestRecorder) Size() int {
	return r.bytesRead
}

// Data returns the bytes that were recorded.
func (r *RequestRecorder) Data() []byte {
	// If body logging is enabled then we return the actual body
	if r.LogBody {
		return r.buf.Bytes()
	}
	// ... otherwise we return <BLOB> placeholder
	return blobBody

    assertThat(body.byteString()).isEqualTo(ByteString.EMPTY)
  }

  @Test
  fun byteStringSeesBom() {
    val body = body("efbbbf68656c6c6f")
    val actual = body.byteString()
    val expected: ByteString = "efbbbf68656c6c6f".decodeHex()
    assertThat(actual).isEqualTo(expected)
  }

  @Test
  fun byteStringClosesUnderlyingSource() {
    val closed = AtomicBoolean()
    val body: ResponseBody =

        SpnegoAuthenticator authenticator = new SpnegoAuthenticator();
        assertNotNull(authenticator);

        // The constant should be accessible and properly named
        // We can't easily test the actual configuration without full DI setup,
        // but we verify the class structure is correct
        assertTrue(true);
    }

    @Test
    public void test_securitySettings_allowUnsecureBasic() throws Exception {

        assertEquals(35000, SmbConstants.DEFAULT_CONN_TIMEOUT);
        // Note: USE_UNICODE and FORCE_UNICODE don't exist in the interface
        // These tests should be removed or replaced with actual constants
    }

    /**
     * Test individual FLAGS2 constants.
     */
    @Test
    @DisplayName("FLAGS2 individual constants are correct")
    void flags2ConstantsTest() {