protected void doStart() {
            super.doStart();
            // This will delay service listener execution at least 150 milliseconds
            Uninterruptibles.sleepUninterruptibly(150, MILLISECONDS);
          }
        };
    Service a =
        new NoOpDelayedService(150) {
          @Override
          protected void doStart() {
            b.startAsync();
            super.doStart();
          }

        errors.add(new IllegalArgumentException("Illegal argument error"));

        SuggestDeleteResponse response = new SuggestDeleteResponse(errors, 150);

        assertTrue(response.hasError());
        assertEquals(3, response.getErrors().size());
        assertEquals(150, response.getTook());
    }

    val delays = mutableListOf(50.µs, 150.µs, -1L)
    redQueue.schedule("task", 100.µs) {
      log += "run@${taskFaker.nanoTime}"
      return@schedule delays.removeAt(0)
    }

    taskFaker.advanceUntil(0.µs)
    assertThat(log).containsExactly()

    taskFaker.advanceUntil(100.µs)
    assertThat(log).containsExactly("run@100000")

    taskFaker.advanceUntil(150.µs)

                .queryTime(150)
                .partialResults(true)
                .facetResponse(facetResponse)
                .build();

        assertEquals(1, result.getDocumentList().size());
        assertEquals(1000, result.getAllRecordCount());
        assertEquals(Relation.EQUAL_TO.toString(), result.getAllRecordCountRelation());
        assertEquals(150, result.getQueryTime());

            }

            @Override
            public int getLtrWindowSize() {
                return 150;
            }
        });

        RescorerBuilder<?> result3 = ltrQueryRescorer.evaluate(params);
        assertNotNull(result3);
        assertEquals(150, ((QueryRescorerBuilder) result3).windowSize().intValue());
    }

        void flagsInDifferentOrder() {
            TestLocking t = new TestLocking();

            // Parse flags in different order
            String[] args = { "smb://test/file.txt", "-i", "4", "-t", "2", "-d", "150" };
            for (int ai = 0; ai < args.length; ai++) {
                if (args[ai].equals("-t")) {
                    ai++;
                    t.numThreads = Integer.parseInt(args[ai]);

indent_style = space

ij_formatter_off_tag = @formatter:off
ij_formatter_on_tag = @formatter:on
ij_formatter_tags_enabled = false

[*.gradle]
ij_continuation_indent_size = 2
indent_size = 2
max_line_length = 150

[*.md]
max_line_length = 80

[*.groovy]
indent_size = 4
ij_continuation_indent_size = 4
max_line_length = 140
ij_groovy_class_count_to_use_import_on_demand = 999

        netServerEnum2.subCommand = (byte) SmbComTransaction.NET_SERVER_ENUM3;
        String lastName = "LAST_SERVER";
        netServerEnum2.reset(0, lastName);

        byte[] dst = new byte[150];
        int bytesWritten = netServerEnum2.writeParametersWireFormat(dst, 0);

        // Verify subcommand
        assertEquals(SmbComTransaction.NET_SERVER_ENUM3 & 0xFF, (dst[0] & 0xFF) | ((dst[1] & 0xFF) << 8));

        HandleInfo expiredHandle = new HandleInfo("/test/file.txt", new HandleGuid(), new byte[16], HandleType.DURABLE_V2, 100, // 100ms timeout
                null);

        // Wait for expiration
        Thread.sleep(150);

        CompletableFuture<HandleInfo> future = reconnector.reconnectHandle(expiredHandle, new IOException("Network error"));

        assertThrows(ExecutionException.class, () -> {
            future.get();

        manager.requestDurableHandle("/test/file.txt", HandleType.DURABLE_V2, 100, // 100ms timeout
                null);

        // Wait for expiration
        try {
            Thread.sleep(150);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

        HandleInfo info = manager.getHandleForReconnect("/test/file.txt");
        assertNull(info);
    }