@Mock
    private CommonServerMessageBlockRequest cancelRequest;

    @BeforeEach
    void setUp() {
        // Reset mocks before each test
        reset(request, nextRequest, splitRequest, cancelRequest);
    }

    @Test
    @DisplayName("Test isResponseAsync returns true when response is async")
    void testIsResponseAsyncTrue() {
        // Given
        when(request.isResponseAsync()).thenReturn(true);

 */
public class RequestDataBuilderTest extends PlainTestCase {

    public void test_newRequestData() {
        // Test newRequestData factory method
        RequestDataBuilder.RequestDataContext context = RequestDataBuilder.newRequestData();

        assertNotNull(context);
    }

    public void test_buildEmptyRequestData() {
        // Test building empty RequestData

      Iterator<? extends E> elements);

  public void testCreation_noArgs() {
    Set<String> set = of();
    assertEquals(Collections.<String>emptySet(), set);
    assertSame(this.<String>of(), set);
  }

  public void testCreation_oneElement() {
    Set<String> set = of("a");
    assertEquals(singleton("a"), set);
  }

  public void testCreation_twoElements() {
    Set<String> set = of("a", "b");

    }

    @Override
    public void debug(Throwable error) {
        logger.debug("", error);
    }

    @Override
    public void info(CharSequence content) {
        logger.info(toString(content));
    }

    @Override
    public void info(CharSequence content, Throwable error) {
        logger.info(toString(content), error);
    }

    @Override
    public void info(Throwable error) {

            this.epoch = 1;
            this.breaking = false;
        }
        
        public synchronized void updateState(int newState) {
            this.leaseState = newState;
            this.lastAccessTime = System.currentTimeMillis();
        }
        
        public synchronized void incrementEpoch() {
            this.epoch++;
        }
        
        public boolean hasReadCache() {

    protected void checkEsInvalidAggregation(String name, Object value) {
        if (value == null || (value instanceof String && ((String) value).isEmpty())) {
            String msg = "Cannot register null or empty aggregation: name=" + name + " value=" + value;
            throw new InvalidQueryRegisteredException(msg);
        }
    }

    private SmartProjectComparator comparator;
    private ProjectDependencyGraph dependencyGraph;

    @BeforeEach
    void setUp() {
        dependencyGraph = new ProjectDependencyGraphStub();
        comparator = new SmartProjectComparator(dependencyGraph);
    }

    @Test
    void testProjectWeightCalculation() {
        // Test that projects with longer downstream chains get higher weights

))n.extend(this.cache[e],b);else for(d in b)f[d]=b[d];return f},get:function(a,b){var c=this.cache[this.key(a)];return void 0===b?c:c[b]},access:function(a,b,c){var d;return void 0===b||b&&"string"==typeof b&&void 0===c?(d=this.get(a,b),void 0!==d?d:this.get(a,n.camelCase(b))):(this.set(a,b,c),void 0!==c?c:b)},remove:function(a,b){var c,d,e,f=this.key(a),g=this.cache[f];if(void 0===b)this.cache[f]={};else{n.isArray(b)?d=b.concat(b.map(n.camelCase)):(e=n.camelCase(b),b in g?d=[b,e]:(d=e,d=d in g?...

        initializeSuggestSettings();
    }

    @AfterClass
    public static void afterClass() throws Exception {
        runner.close();
        runner.clean();
    }

    @Before
    public void setUp() throws Exception {
        converter = new AnalyzerConverter(client, settings);
    }

    private static void createTestIndex() throws Exception {
        // Create index with custom analyzers

    void getResponseTimeout_default() {
        // Arrange
        Request req = mock(Request.class);
        when(cfg.getResponseTimeout()).thenReturn(2222);

        // Act & Assert
        assertEquals(2222, transport.getResponseTimeout(req));
    }

    @Test
    @DisplayName("Basic getters: address, hostName, inflight, sessions")
    void basicGetters() {