AbstractFuture<String> future = new AbstractFuture<String>() {};
    WaiterThread waiter = new WaiterThread(future);
    waiter.start();
    waiter.awaitWaiting();
    PollingThread poller = new PollingThread(future);
    poller.start();
    PollingThread poller2 = new PollingThread(future);
    poller2.start();
    PollingThread poller3 = new PollingThread(future);
    poller3.start();

            this.upgradeParser = new UpgradeParser();
            Map<String, CommandMethods> commandExecute = new HashMap<>();
            commandExecute.put("!", new CommandMethods(this::shell, this::defaultCompleter));
            commandExecute.put("cd", new CommandMethods(this::cd, this::cdCompleter));
            commandExecute.put("pwd", new CommandMethods(this::pwd, this::defaultCompleter));

    void testRoundTripFull() throws IOException {
        // Arrange – create a fully populated token
        ASN1ObjectIdentifier mech = new ASN1ObjectIdentifier("1.2.840.113554.1.2.2");
        byte[] tokenArray = new byte[] { 1, 2, 3 };
        byte[] mic = new byte[] { 9, 9, 9 };
        NegTokenTarg original = new NegTokenTarg(NegTokenTarg.ACCEPT_COMPLETED, mech, tokenArray, mic);

        // Act – serialise and parse back

        // Verify no data was written
        assertArrayEquals(new byte[100], dst);
    }

    @Test
    @DisplayName("Test writeParametersWireFormat writes correct data")
    void testWriteParametersWireFormat() throws Exception {
        netShareEnum = new NetShareEnum(realConfig);
        byte[] dst = new byte[256];
        int dstIndex = 0;

        final ScheduledJob job = new ScheduledJob();
        assertFalse(job.isLoggingEnabled());
    }

    @Test
    public void test_isEnabled_true() {
        final ScheduledJob job = new ScheduledJob();
        job.setAvailable(Constants.T);
        assertTrue(job.isEnabled());
    }

    @Test
    public void test_isEnabled_false() {
        final ScheduledJob job = new ScheduledJob();

        DummyPlainSMB next = new DummyPlainSMB();
        DummyAndXBlock block = new DummyAndXBlock(next);

        assertNotNull(block);
        assertSame(next, block.andx, "andx should reference provided SMB");
    }

    @Test
    @DisplayName("getBatchLimit defaults to 0")
    void testGetBatchLimitDefault() {
        DummyAndXBlock block = new DummyAndXBlock();

        NtlmPasswordAuthenticator baseAuth = new NtlmPasswordAuthenticator("domain", "user", new String(basePassword));
        NtlmPasswordAuthenticator startAuth = new NtlmPasswordAuthenticator("domain", "user", new String(diffAtStart));
        NtlmPasswordAuthenticator middleAuth = new NtlmPasswordAuthenticator("domain", "user", new String(diffAtMiddle));

        CIFSContext context = new BaseContext(new PropertyConfiguration());
        PersistentHandleManager manager = new PersistentHandleManager(context);
        
        // Create persistent handle
        HandleGuid guid = manager.requestDurableHandle(
            "/test/file.txt",
            HandleType.PERSISTENT,
            0,
            null
        );
        
        byte[] fileId = new byte[16];

  public void testDelegateRejection() {
    AtomicInteger numCalls = new AtomicInteger();
    AtomicBoolean reject = new AtomicBoolean(true);
    SequentialExecutor executor =
        new SequentialExecutor(
            new Executor() {
              @Override
              public void execute(Runnable r) {
                if (reject.get()) {
                  throw new RejectedExecutionException();
                }

    future.setException(new Exception());
    listener.assertRun();
  }

  public void testListenLaterCancelled() {
    CountingRunnable listener = new CountingRunnable();

    future.addListener(listener, directExecutor());
    listener.assertNotRun();

    future.cancel(false);
    listener.assertRun();
  }

  public void testListenLaterInterrupted() {
    CountingRunnable listener = new CountingRunnable();