StreamProcessor onObservationRefill