eventBus.post(EVENT);

    assertEquals("Cause should be available.", exception, handler.exception);
    assertEquals("EventBus should be available.", eventBus, handler.context.getEventBus());
    assertEquals("Event should be available.", EVENT, handler.context.getEvent());
    assertEquals("Subscriber should be available.", subscriber, handler.context.getSubscriber());
    assertEquals(
        "Method should be available.",

    eventBus.post(EVENT);

    assertEquals("Cause should be available.", exception, handler.exception);
    assertEquals("EventBus should be available.", eventBus, handler.context.getEventBus());
    assertEquals("Event should be available.", EVENT, handler.context.getEvent());
    assertEquals("Subscriber should be available.", subscriber, handler.context.getSubscriber());
    assertEquals(
        "Method should be available.",

        assertNotNull("Encoded result should not be null", encoded);
        final byte[] decoded = Base64Util.decode(encoded);
        assertEquals("Decoded should have same length", 2, decoded.length);
        assertEquals("First byte should match", twoBytes[0], decoded[0]);
        assertEquals("Second byte should match", twoBytes[1], decoded[1]);
    }

    /**
     * Test backward compatibility with standard Base64
     *

    // Test default state of not started.
    assertEquals(1, listenerLatch.getCount());
    assertFalse(task.isDone());
    assertFalse(task.isCancelled());

    // Start the task to put it in the RUNNING state.  Have to use a separate
    // thread because the task will block on the task latch after unblocking
    // the run latch.
    exec.execute(task);
    runLatch.await();
    assertEquals(1, listenerLatch.getCount());

        extraParameters: String,
        os: Os = Os.LINUX,
    ) {
        assertEquals(BuildStep.ExecutionMode.DEFAULT, steps.getGradleStep("GRADLE_RUNNER").executionMode)

        assertEquals(
            expectedRunnerParam(extraParameters, os),
            steps.getGradleStep("GRADLE_RUNNER").gradleParams,
        )
        assertEquals("clean myTask", steps.getGradleStep("GRADLE_RUNNER").tasks)
    }

        assertEquals("TESTSHARE", tree.share);
        assertEquals("testService", tree.service);
        assertEquals(0, tree.connectionState);

        // Test constructor with null service
        tree = new SmbTree(session, "testShare", null);
        assertEquals("TESTSHARE", tree.share);
        assertEquals("?????", tree.service);
        assertEquals(0, tree.connectionState);

        String directoryName = "testDir";
        SmbComCreateDirectory smbCom = new SmbComCreateDirectory(mockConfig, directoryName);

        assertEquals(ServerMessageBlock.SMB_COM_CREATE_DIRECTORY, smbCom.getCommand());
        assertEquals(directoryName, smbCom.getPath());
    }

    @Test
    void testWriteParameterWordsWireFormat() {
        // This method is empty, so it should return 0

            assertEquals(0, smbComTreeDisconnect.writeParameterWordsWireFormat(null, 0));
            assertEquals(0, smbComTreeDisconnect.writeBytesWireFormat(null, 0));
            assertEquals(0, smbComTreeDisconnect.readParameterWordsWireFormat(null, 0));
            assertEquals(0, smbComTreeDisconnect.readBytesWireFormat(null, 0));
        }

        @Test

        BoolQueryBuilder boolResult = (BoolQueryBuilder) result;
        assertTrue(boolResult.hasClauses());
        assertEquals(1, boolResult.must().size());
        assertEquals(1, boolResult.should().size());
        assertEquals(1, boolResult.mustNot().size());
    }

    // Test convertBooleanQuery with empty BooleanQuery
    @Test

        LogStream.setLevel(0);
        assertEquals(0, LogStream.level);

        LogStream.setLevel(1);
        assertEquals(1, LogStream.level);

        LogStream.setLevel(3);
        assertEquals(3, LogStream.level);

        LogStream.setLevel(10);
        assertEquals(10, LogStream.level);

        // Test negative level
        LogStream.setLevel(-1);
        assertEquals(-1, LogStream.level);
    }

    @Test