class DeserializationSchemaWrapper implements PubSubDeserializationSchema<T> {

	@Override
	public boolean isEndOfStream(T t) {
		return deserializationSchema.isEndOfStream(t);
	}

	  DeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema);

}