Updated Stream Processor Observer Class