Implement async versions of process_pending_events