### Question:
DeserializationSchemaWrapper implements PubSubDeserializationSchema<T> { @Override public boolean isEndOfStream(T t) { return deserializationSchema.isEndOfStream(t); } DeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema); @Override boolean isEndOfStream(T t); @Override T deserialize(PubsubMessage pubsubMessage); @Override TypeInformation<T> getProducedType();  }### Answer:
@Test public void testEndOfStream() { String input = "some-input"; when(deserializationSchema.isEndOfStream(any())).thenReturn(true); assertThat(deserializationSchemaWrapper.isEndOfStream(input), is(true)); verify(deserializationSchema, times(1)).isEndOfStream(input); }