int decodedSize = context.decode(buffer, 0, buffer.length);

            // Assert
            assertEquals(12, decodedSize);
            assertArrayEquals(new int[] { 1, 2 }, context.getHashAlgos());
            assertArrayEquals(new byte[] { 0x0A, 0x0B, 0x0C, 0x0D }, context.getSalt());
        }

        @Test
        @DisplayName("Should handle empty arrays in decode")

  }

  @Test fun `cannot decode malformed utc time`() {
    val bytes = "170d3139313231362333303231305a".decodeHex()
    assertFailsWith<ProtocolException> {
      Adapters.UTC_TIME.fromDer(bytes)
    }.also { expected ->
      assertThat(expected).hasMessage("Failed to parse UTCTime 191216#30210Z")
    }
  }

  @Test fun `cannot decode generalized time with offset`() {

              "00010000003b00049df00112"
          ).decodeHex(),
      )
    assertThat(decoded).containsExactly(InetAddress.getByName("157.240.1.18"))
  }

  @Test
  fun testGoogleDotComDecodingFromGoogleIPv6() {
    val decoded =
      decodeAnswers(
        hostname = "test.com",
        byteString =
          (

                if (info == null) { /* YOYOYO */
                    info = new DfsEnumStruct();
                }
                info.decode(_src);

            }
            final int _totalentriesp = _src.dec_ndr_long();
            if (_totalentriesp != 0) {
                totalentries.decode(_src);

            }
            retval = _src.dec_ndr_long();
        }
    }

      |-----END PRIVATE KEY-----
      |
      """.trimMargin()
    try {
      decode(certificatePem)
      fail<Any>()
    } catch (expected: IllegalArgumentException) {
      assertThat(expected.message).isEqualTo("string does not include a private key")
    }
    try {
      decode(pkcs8Pem)
      fail<Any>()
    } catch (expected: IllegalArgumentException) {

        // Use the encoded buffer for decoding
        NdrBuffer src = new NdrBuffer(encodeBuffer, 0);
        netdfs.DfsInfo1 decodedInfo1 = new netdfs.DfsInfo1();
        decodedInfo1.decode(src);

        assertEquals(info1.entry_path, decodedInfo1.entry_path);
    }

    @Test
    void testDfsInfo1_EncodeDecode_NullEntryPath() throws NdrException {
        netdfs.DfsInfo1 info1 = new netdfs.DfsInfo1();

    @Test
    @DisplayName("Should define decode method")
    void testDecodeMethod() throws SMBProtocolDecodingException {
        // Given
        byte[] buffer = new byte[10];
        int bufferIndex = 0;
        int len = 10;
        when(mockDecodable.decode(buffer, bufferIndex, len)).thenReturn(10);

        // When
        int decodedLength = mockDecodable.decode(buffer, bufferIndex, len);

        // Then

// Reader - JSON record reader for S3Select.
type Reader struct {
	args       *ReaderArgs
	decoder    *jstream.Decoder
	valueCh    chan *jstream.MetaValue
	readCloser io.ReadCloser
}

// Read - reads single record.
func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
	v, ok := <-r.valueCh
	if !ok {
		if err := r.decoder.Err(); err != nil {
			return nil, errJSONParsingError(err)
		}
		return nil, io.EOF
	}

        m.ptype = 0; // Request type
        NdrBuffer buf = new NdrBuffer(new byte[1024], 0);
        m.encode(buf);

        buf.setIndex(0);
        // Decode will throw exception as ptype 0 is not a valid response type
        assertThrows(NdrException.class, () -> m.decode(buf));
    }

    @Test
    void testRoundTripEncodeDecodeForResponseType() throws Exception {
        // Create a properly formatted response message

        }

        @Test
        @DisplayName("Should inherit decode from Decodable")
        void shouldInheritDecodeMethod() throws NoSuchMethodException {
            // Verify method is inherited
            assertNotNull(AllocInfo.class.getMethod("decode", byte[].class, int.class, int.class));
            assertEquals(int.class, AllocInfo.class.getMethod("decode", byte[].class, int.class, int.class).getReturnType());
        }