处理 Observable 生成的 IDisposable 项目

发布于 2024-09-24 17:05:19 字数 498 浏览 3 评论 0原文

我有一个 Observable （WebResponse 实现 IDisposable）

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

（忽略毫无意义的查询！）

所以，我放弃 WebResponse 实例，无需对其调用 Dispose 。这看起来很糟糕。

更抽象地说：如果我有一个 Observable，我如何处理生成的项目的处置？

原文

I have an Observable<WebResponse> (WebResponse implements IDisposable)

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

(Ignore the pointlessness of the query!)

so, I'm discarding WebResponse instances without calling Dispose on them. This seems bad.

More abstractly: If I have an Observable<IDisposable>, how do I deal with the disposal of generated items?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

转角预定愛 2024-10-01 17:05:19

假设您有一个方法 WebResponse CreateMyWebResponse() 使用 Observable.Using，如下所示：

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

Assuming that you have a method WebResponse CreateMyWebResponse() use Observable.Using like this:

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

回复收藏 0 原文

情话难免假 2024-10-01 17:05:19

将 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)
}

F# 中的假设 Some/None（我显然开始忘记我的 C#）。

Change the Where and Do bits to something like

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

perhaps?

EDIT

Based on your edit, how about

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

now? This would generalize into something like

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)
}

assuming Some/None as in F# (I am apparently starting to forget my C#).

回复收藏 0 原文

~没有更多了~