Утилизация идентифицируемых объектов, сгенерированных Observable

Question

У меня есть 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(); })

возможно

EDIT

На основании ваших правок, как насчет

.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 #).