* @return the total number of bytes read into the buffer, or -1 if there is no more data
     * @throws IOException if an I/O error occurs
     */
    @Override
    public int read(final byte[] b, final int off, final int len) throws IOException {
        return inputStream.read(b, off, len);
    }

    /**
     * Reads some number of bytes from the input stream and stores them into the buffer array b.
     *

        GeoInfo geoInfo = null;
        FacetInfo facetInfo = null;
        HighlightInfo highlightInfo = null;
        String sort = "";
        int startPosition = 0;
        int pageSize = 10;
        int offset = 0;
        String[] extraQueries = new String[0];
        Map<String, Object> attributes = new HashMap<>();
        Locale locale = Locale.ENGLISH;

    void testReadBytesWireFormatNoop() {
        byte[] buffer = new byte[10];
        int used = cmd.readBytesWireFormat(buffer, 0);
        assertEquals(0, used, "readBytesWireFormat is unimplemented and must return 0");
    }

    private static byte[] subArray(byte[] src, int offset, int length) {
        byte[] dst = new byte[length];
        System.arraycopy(src, offset, dst, 0, length);

     */
    public static SmbResourceException fileHandleExhausted(int errorCode) {
        return new SmbResourceException("File handle limit exceeded", errorCode, ResourceType.FILE_HANDLE);
    }

    /**
     * Static factory for connection pool exhaustion
     */
    public static SmbResourceException connectionPoolExhausted(int errorCode, int poolSize) {

        for (int i = 0; i < num; i++) {
          list.add(counter.getAndIncrement());
        }
        builder.addAll(list);
      }
    },
    ADD_ITERABLE {
      @Override
      void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) {
        List<Long> list = new ArrayList<>();
        long num = random.nextInt(10);
        for (int i = 0; i < num; i++) {

    int keyCount = stream.readInt();
    if (keyCount < 0) {
      throw new InvalidObjectException("Invalid key count " + keyCount);
    }
    ImmutableMap.Builder<Object, ImmutableSet<Object>> builder = ImmutableMap.builder();
    int tmpSize = 0;

    for (int i = 0; i < keyCount; i++) {
      Object key = requireNonNull(stream.readObject());
      int valueCount = stream.readInt();

        this.sourceKey = sourceKey;
        this.chunks = chunks;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.Encodable#encode(byte[], int)
     */
    @Override
    public int encode(final byte[] dst, int dstIndex) {
        final int start = dstIndex;

        System.arraycopy(this.sourceKey, 0, dst, dstIndex, 24);
        dstIndex += 24;

        SMBUtil.writeInt4(this.chunks.length, dst, dstIndex);

        // Initialize QueryFieldConfig
        QueryFieldConfig queryFieldConfig = new QueryFieldConfig();
        queryFieldConfig.init();
        ComponentUtil.register(queryFieldConfig, "queryFieldConfig");

        // Initialize QueryParser
        QueryParser queryParser = new QueryParser();
        queryParser.init();
        ComponentUtil.register(queryParser, "queryParser");

        // Initialize QueryProcessor if needed

            } else {
                return 1;
            }
        }

        int g = compareStrings(md.groupId, vmd.groupId);

        if (g == 0) {
            int a = compareStrings(md.artifactId, vmd.artifactId);
            if (a == 0) {
                if (compareVersion) {
                    int v = compareStrings(md.version, vmd.version);
                    if (v == 0) {

    }

    @Test
    void testEngineDigestWithBuffer() {
        // Test engineDigest(byte[] buf, int offset, int len)
        HMACT64 hmac = new HMACT64(TEST_KEY);
        hmac.engineUpdate(TEST_DATA, 0, TEST_DATA.length);

        byte[] buffer = new byte[32];
        int bytesWritten = hmac.engineDigest(buffer, 5, 16);

        assertEquals(16, bytesWritten);