如何使用URL查詢處理WCF-OData中的延續？

Question

我正在使用指向OData端點的WCF數據服務。如果我使用DataServiceQuery，則可以毫無困難地管理延續。

var collection = new DataServiceCollection<T>(); 
collection.LoadCompleted += (sender, e) => 
    { 
     if (e.Error != null) 
     { 
      callback(null, e.Error); 
      return; 
     } 

     var thisCollection = (DataServiceCollection<T>) sender; 
     if (thisCollection.Continuation != null) 
     { 
      thisCollection.LoadNextPartialSetAsync(); 
     } 
     else 
     { 
      var items = thisCollection.ToList(); 
      callback(items, e.Error); 
     } 
    }; 
collection.LoadAsync(query); 

不過，我看不出你如何能爲DataServiceContext.BeginExecute做同樣的（字符串的URL，...）方法。

_odataContext.BeginExecute<T>(new Uri(requestUrl), x => 
{ 
    var items = _odataContext.EndExecute<T>(x); 

    //not sure how to get the rest of the items with this method 
}); 

如何使用基於url的查詢方法，但仍然得到延續支持？

Answer 1

的同步樣本（使其更簡單）：

var r = ctx.Execute<Product>(new Uri("http://services.odata.org/Northwind/Northwind.svc/Products")); 
QueryOperationResponse<Product> response = (QueryOperationResponse<Product>)r; 
response.Count(); 
Console.WriteLine(response.GetContinuation()); 

總之，Execute方法返回QueryOperationResponse，其實現IEnumerable的實例，但也暴露了延續。

Answer 2

爲了完整起見，下面是完整的功能，它遵循URL查詢的延續。

public void ExecuteFullQuery<T>(Uri requestUrl, Action<IEnumerable<T>> callback) 
{ 
    var list = new List<T>(); 
    ExecuteFullQueryImpl(requestUrl, list, callback); 
} 

private void ExecuteFullQueryImpl<T>(Uri requestUrl, List<T> items, Action<IEnumerable<T>> callback) 
{ 
    _odataContext.BeginExecute<T>(requestUrl, x => 
    { 
     var results = _odataContext.EndExecute<T>(x); 
     if (results != null) 
      items.AddRange(results.ToList()); 

     var response = (QueryOperationResponse<T>)results; 
     var continuation = response.GetContinuation(); 
     if (continuation != null) 
     { 
      ExecuteFullQueryImpl(continuation.NextLinkUri, items, callback); 
     } 
     else 
     { 
      callback(items); 
     } 
    }, 
    null); 
} 

Answer 3

使用一個懶惰的枚舉

public IEnumerable<Product> GetProducts() 
{ 
    Uri request = new Uri("http://services.odata.org/Northwind/Northwind.svc/Products"); 

    var response = (QueryOperationResponse<Product>)ctx.Execute<Product>(request); 

    while (true) 
    { 
     foreach (Product p in response) 
     { 
      yield return p; 
     } 

     var continuation = response.GetContinuation(); 
     if (continuation == null) 
     { 
      yield break; 
     } 

     response = ctx.Execute(continuation); 
    } 
}