@Override
    public DynamicMessage parse(final InputStream inputStream) {
        try {
            return DynamicMessage.newBuilder(messageDescriptor)
                    .mergeFrom(inputStream, ExtensionRegistryLite.getEmptyRegistry())
                    .build();
        } catch (IOException e) {
            throw new ShenyuGrpcException("Unable to merge from the supplied input stream", e);
        }
    }
@Test
    public void testParseThrowException() {
        InputStream inputStream = new ByteArrayInputStream("test".getBytes());
        assertThrows(RuntimeException.class, () -> dynamicMessageMarshaller.parse(inputStream));
    }