17 #ifndef SCHEMA_PROCESSOR_HPP_
18 #define SCHEMA_PROCESSOR_HPP_
22 #ifdef KAA_USE_CONFIGURATION
36 class SchemaProcessor :
public ISchemaProcessor
45 void loadSchema(
const std::uint8_t * buffer, std::size_t size);
50 void subscribeForSchemaUpdates(ISchemaUpdatesReceiver &receiver);
51 void unsubscribeFromSchemaUpdates(ISchemaUpdatesReceiver &receiver);
53 virtual SchemaPtr getSchema()
const {
return schema_; }
56 typedef avro::ValidSchema Schema;
59 KaaObservable<void (std::shared_ptr<avro::ValidSchema>), ISchemaUpdatesReceiver *> schemaUpdatesSubscribers_;