pub(crate) async fn run_trigger_service(
    stream: TriggerRequestStream
) -> Result<(), Error>