Got to fix how process_data works and turn it into a correlator observable.