### Question:
DeserializationSchemaWrapper implements PubSubDeserializationSchema<T> { @Override public TypeInformation<T> getProducedType() { return deserializationSchema.getProducedType(); } DeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema); @Override boolean isEndOfStream(T t); @Override T deserialize(PubsubMessage pubsubMessage); @Override TypeInformation<T> getProducedType();  }### Answer:
@Test public void testProducedType() { TypeInformation<String> typeInformation = TypeInformation.of(String.class); when(deserializationSchema.getProducedType()).thenReturn(typeInformation); assertThat(deserializationSchemaWrapper.getProducedType(), is(typeInformation)); verify(deserializationSchema, times(1)).getProducedType(); }