@Override
    public InputStream stream(final DynamicMessage abstractMessage) {
        return abstractMessage.toByteString().newInput();
    }
@Test
    public void testStream() {
        DynamicMessage dynamicMessage = mock(DynamicMessage.class, RETURNS_DEEP_STUBS);
        InputStream inputStream = mock(InputStream.class);
        when(dynamicMessage.toByteString().newInput()).thenReturn(inputStream);
        InputStream actualInputStream = dynamicMessageMarshaller.stream(dynamicMessage);
        assertEquals(inputStream, actualInputStream);
    }