FromAsyncPattern 会处置不再使用的资源吗？

Question

FromAsyncPattern 会关闭我的网络响应吗：

var o = Observable.Return(HttpWebRequest.Create("http://foo.com"))
                  .SelectMany(r => Observable.FromAsyncPattern<WebResponse>(
                      r.BeginGetResponse,
                      r.EndGetResponse)())
                  .Select(r => r.ContentLength);
// The response is now disposed

还是我必须手动执行此操作？

var o = Observable.Return(HttpWebRequest.Create("http://foo.com"))
                  .SelectMany(r => Observable.FromAsyncPattern<WebResponse>(
                      r.BeginGetResponse,
                      r.EndGetResponse)())
                  .Select(r => Tuple.Create(r, r.ContentLength))
                  .Do(t => t.Item1.Close())
                  .Select(t => t.Item2);

如果我必须手动完成，还有比这更好的方法吗？

Answer 1

Observable.Using 可用于此目的，如下所示：

var o = Observable.Return(HttpWebRequest.Create("http://www.google.com"))
                  .SelectMany(r => Observable.FromAsyncPattern<WebResponse>(
                      r.BeginGetResponse,
                      r.EndGetResponse)())
                  .SelectMany(r =>
                  {
                      return Observable.Using( () => r, (resp) => Observable.Return(resp.ContentLength));
                  });

Answer 2

作为 Using 查询的稍微简洁的版本是这样的：

var o =
    from rq in Observable.Return(HttpWebRequest.Create("http://foo.com"))
    from cl in Observable.Using(() => rq.GetResponse(),
        rp => Observable.Return(rp.ContentLength))
    select cl;

我建议将 Scheduler.ThreadPool 添加到至少第一个 Return 以使可观察在后台线程上执行 - 否则默认为 Scheduler.Immediate 。

Answer 3

我不相信 FromAsyncPattern 可以关闭您的资源，即使它想这样做。它没有足够的信息来了解如何在其他地方使用进行异步调用的对象（本例中为 HttpWebRequest）或从异步调用返回的对象（本例中为 WebResponse）来了解何时将其保存到处置。

也就是说，您仍然可以手动关闭资源，而无需额外的 Do 和 Select 调用。只需将第一个示例中的 Select 更改为：

.Select(r => { using (r) { return r.ContentLength; }});

据我所知，唯一会调用 Dispose 的 Rx 运算符是 Observable.Using。然而，根据它的签名，它如何或是否可以应用在这里并不是很明显，所以我采用了上述方法。