Call on_data on reactor thread