由Observable

Question

產生處置IDisposable的項目我有一個Observable<WebResponse>（WebResponse器具IDisposable）

responseObservable 
    .Where(webResponse => webResponse.ContentType.StartsWith("text/html")) 
    .Select(webResponse => webResponse.ContentLength) 
    .Run() 

（忽略查詢無意義！）

所以，我放棄WebResponse情況下不會對呼叫Dispose他們。這看起來很糟糕。

更抽象地說：如果我有Observable<IDisposable>，我該如何處理生成的物品？

Answer 1

假設你有一個方法WebResponse CreateMyWebResponse()使用Observable.Using這樣的：

var responseObservable = Observable.Using(() => CreateMyWebResponse(), Observable.Return); 

Answer 2

更改Where和Do位像

.Do(webResponse => { 
    if (webResponse.ContentType.StartsWith("text/html")) 
     ProcessAndDispose(webResponse); 
    else 
     webResponse.Dispose(); }) 

吧？

編輯

根據您的編輯，怎麼樣

.Select(webResponse => { 
    int r = -1; 
    if (webResponse.ContentType.StartsWith("text/html")) 
     r = webResponse.ContentLength; 
    webResponse.Dispose(); 
    return r; }) 
.Where(i => i != -1) 

現在呢？這將推廣到類似

FilterProjectDispose(e, pred, proj) { 
    e.Select(x => { 
     using(x) { 
      if (pred(x)) return Some(proj(x)); 
      else return None; }}) 
    .Where(x => x.IsSome) 
    .Select(x => x.Value) 
} 

假設Some/None在F＃（我顯然開始忘記我的C＃）。