return new PopulatableMapAsMultimap<>();
    }

    @SuppressWarnings("unchecked") // all methods throw immediately
    PopulatableMapAsMultimap() {
      this.map = new HashMap<>();
      this.unusableDelegate =
          (SetMultimap<K, V>)
              newProxyInstance(
                  SetMultimap.class.getClassLoader(),
                  new Class<?>[] {SetMultimap.class},

            throw new UnsupportedOperationException();
        }

        @Override
        public String getScheme() {
            throw new UnsupportedOperationException();
        }

        @Override
        public String getServerName() {
            throw new UnsupportedOperationException();
        }

        @Override
        public int getServerPort() {

        DynamicProperties systemProps = new DynamicProperties(file);
        ComponentUtil.register(systemProps, "systemProperties");

        relatedContentHelper = new RelatedContentHelper() {
            @Override
            public List<RelatedContent> getAvailableRelatedContentList() {
                return mockBhv.getTestData();
            }
        };

        mockBhv = new MockRelatedContentBhv();

            InputStream is = new ByteArrayInputStream("test".getBytes());
            assertThrows(IOException.class, () -> Transport.readn(is, new byte[5], 0, 10));
        }

        @Test
        @DisplayName("readn should return 0 when no more bytes available")
        void shouldReturnZeroWhenStreamEmpty() throws IOException {
            InputStream is = new ByteArrayInputStream("Hi".getBytes());

    @Test
    @DisplayName("readn should handle EOF correctly")
    void testReadnEOF() throws IOException {
        byte[] buffer = new byte[10];
        ByteArrayInputStream bais = new ByteArrayInputStream(new byte[0]);

        int bytesRead = SessionServicePacket.readn(bais, buffer, 0, 5);

        assertEquals(0, bytesRead);
    }

    @Test
    @DisplayName("readn should handle multiple read calls")

        GroupCQ cq = new GroupCQ();
        if (queryLambda != null) {
            queryLambda.callback(cq);
        }
        FilterAggregationBuilder builder = regFilterA(name, cq.getQuery());
        if (opLambda != null) {
            opLambda.callback(builder);
        }
        if (aggsLambda != null) {
            GroupCA ca = new GroupCA();
            aggsLambda.callback(ca);

            Smb2Lock[] locks = new Smb2Lock[] { new Smb2Lock(0L, 100L, Smb2Lock.SMB2_LOCKFLAG_EXCLUSIVE_LOCK),
                    new Smb2Lock(200L, 300L, Smb2Lock.SMB2_LOCKFLAG_SHARED_LOCK), new Smb2Lock(500L, 100L, Smb2Lock.SMB2_LOCKFLAG_UNLOCK) };

            Smb2LockRequest req = new Smb2LockRequest(mockConfig, testFileId, locks);
            byte[] buffer = new byte[512];

    }

    @Test
    void testEquals() {
        ToolchainModel tm1 = new ToolchainModel();
        tm1.setType("jdk");
        tm1.addProvide("version", "1.5");
        tm1.addProvide("vendor", "sun");
        Xpp3Dom configuration1 = new Xpp3Dom("configuration");
        Xpp3Dom jdkHome1 = new Xpp3Dom("jdkHome");
        jdkHome1.setValue("${env.JAVA_HOME}");
        configuration1.addChild(jdkHome1);

    public SmbPipeResource getPipe(final String url, final int pipeType) throws CIFSException {
        try {
            return new SmbNamedPipe(url, pipeType, this);
        } catch (final MalformedURLException e) {
            throw new CIFSException("Invalid URL " + url, e);
        }
    }

    /**
     * Wraps a new context, allowing subclasses to provide custom wrapping behavior.
     *
     * @param newContext the context to wrap

        byte[] buf = new byte[length];
        Arrays.fill(buf, (byte) 0xFF);
        return buf;
    }

    @Test
    @DisplayName("constructor initialises command and parameters correctly")
    void testConstructorInitialisesFields() throws Exception {
        int level = 42;
        Trans2QueryFSInformation cmd = new Trans2QueryFSInformation(level);