IEntityManagerAsync EndExecuteQuery Return Value

private IEnumerator<Int32> InitViewModel(AsyncEnumerator ae)
{            
    BusyText = "Loading...";
    
    // Run the following query serially
    Repository.BeginExecuteQuery<Staff>(QueryNames.LoggedInStaff, ae.End(), null);

    // Yield until one query finishes (1 value in yield return)
    yield return 1;

    // process results of async query            
    //
    // Since the EndExecuteQuery, via my wrapper, now returns a EntityFetchedEventArgs 
    // intead of IEnumerable results we can check for cancelation
    // For example:
    //
    // if (Repository.EndExecuteQuery<Staff>(ae.DequeueAsyncResult()).Cancelled)
    _loggedInStaff = Repository.EndExecuteQuery<Staff>(ae.DequeueAsyncResult()).Result.ToList()[0];            
                          
    // Run the following two queries in parallel
    var arAssociatedClubsStaff = Repository.BeginExecuteQuery<Staff>(QueryNames.AssociatedClubsStaff, ae.End(), null, _loggedInStaff);
    var arAuthorizedClubs = Repository.BeginExecuteQuery<Club>(QueryNames.AuthorizedClubs, ae.End(), null, _loggedInStaff);

    // Yield until the two above queued up query to finishes (2 value in yield return)
    yield return 2;

    // Process the results
    _associatedClubsStaffList = Repository.EndExecuteQuery<Staff>(arAssociatedClubsStaff).Result.ToList();
    _authorizedClubsList = Repository.EndExecuteQuery<Club>(arAuthorizedClubs).Result.ToList();

    // Clear the async queue inbox to prevent memory leaks
    ae.DequeueAsyncResult();
    ae.DequeueAsyncResult();
        
    IsBusy = false;
   
    // and finally, we can't leave the iterator "hanging" - we need
    // to let it know we're done
    yield break;
} 

Repository.Query(Mass.Persistence.QueryNames.LoggedInStaff,
                           delegate(IEnumerable results)
                           {
                               _loggedInStaff = results.Cast<Staff>().ToList()[0];

                               var task = AsyncParallelTask.Create();
                               
                               task.AddAsyncQuery(1, x => Repository.GetQuery<LeadStatus>().OrderBy(ls => ls.Description));
                               task.AddAsyncQuery(2, x => Repository.GetQuery<LeadSource>().OrderBy(ls => ls.Description));
                               task.AddAsyncQuery(3, x => Repository.GetQuery<MktSource>().OrderBy(ms => ms.Description));
                               task.AddAsyncQuery(4, x => Repository.GetQuery<DigitalAddressType>().OrderBy(da => da.Description));
                               task.AddAsyncQuery(5, x => Repository.GetQuery<CorporateGroup>().OrderBy(cg => cg.Description));
                               task.AddAsyncQuery(6, x => Repository.GetQuery<Club>(Mass.Persistence.QueryNames.AuthorizedClubs, _loggedInStaff).OrderBy(c => c.ClubDescription));
                               task.AddAsyncQuery(7, x => Repository.GetQuery<Staff>(Mass.Persistence.QueryNames.AssociatedClubsStaff, _loggedInStaff).OrderBy(s => s.User.Person.LastName));
                               task.Execute(delegate(AsyncParallelTaskCompletedArgs cb)
                               {                                  
                                   var q1Result = ((EntityFetchedEventArgs<LeadStatus>)cb.CompletionMap[1]);
                                   var q2Result = ((EntityFetchedEventArgs<LeadSource>)cb.CompletionMap[2]);
                                   var q3Result = ((EntityFetchedEventArgs<MktSource>)cb.CompletionMap[3]);
                                   var q4Result = ((EntityFetchedEventArgs<DigitalAddressType>)cb.CompletionMap[4]);
                                   var q5Result = ((EntityFetchedEventArgs<CorporateGroup>)cb.CompletionMap[5]);
                                   var q6Result = ((EntityFetchedEventArgs<Club>)cb.CompletionMap[6]);
                                   var q7Result = ((EntityFetchedEventArgs<Staff>)cb.CompletionMap[7]);
                                   
                                   LeadStatusList = new ObservableCollection<LeadStatus>(q1Result.Result.ToList());
                                   LeadSourceList = new ObservableCollection<LeadSource>(q2Result.Result.ToList());
                                   MktSourceList = new ObservableCollection<MktSource>(q3Result.Result.ToList());
                                   DigitalAddressTypeList = new ObservableCollection<DigitalAddressType>(q4Result.Result.ToList());
                                   CorporateGroupList = new ObservableCollection<CorporateGroup>(q5Result.Result.ToList());
                                   ClubList = new ObservableCollection<Club>(q6Result.Result.ToList());
                                   StaffList = new ObservableCollection<Staff>(q7Result.Result.ToList());
                                   IsBusy = false;
                               });
                           });