RX订阅后处理

Question

我有一个包含可观察的热点的类。它进行一些图像转换并收集指标（为简单起见，示例中为int）

public class Provider
{
  public IObservable<(int Metric, Bitmap Image)> HotObservable { get; }

  public Provider()
  {
    HotObservable = Observable.Interval(TimeSpan.FromSeconds(5))
      .Select(x => ...) // Some processing here
      .Where(x => ...) // Some conditions
      .Publish() // Make it hot
      .RefCount(); // Stay connected while there are subscription
  }

}

我想在没有其他可观察的图像的情况下公开指标而没有图像：

public IObservable<int> MetricsObservable { get; } = HotObservable.Select(x => x.Metric);

问题

客户可以订阅他们中的任何一个，但之后应处理Bitmap。

示例客户代码：

public void SubscribeClient()
{
  MetricsObservable.Subscribe(metric => AccumulateMetrics(metric));
  HotObservable(x => 
  {
    if (x.Image.Width < 1024)
      UploadImage(x.Image);

    // I could dispose image here in this case
  });
}

更糟的情况：

public void SubscribeClient()
{
  MetricsObservable.Subscribe(metric => AccumulateMetrics(metric));
  // No way to dispose bitmap because it's not here
}

问题：在RX中，是否有某种处理程序在完成所有订阅后便会触发？也许还有另一种方法可以实现类似的行为？

Answer 1

[从本质上讲，Observable可以被任何客户端使用。在您的特定情况下，谁决定何时和由谁处置资源？最坏的情况是，一个客户端会在允许另一个实例使用该实例之前将其处置。在我看来，处置资源完全不是消费者的责任。无论订阅了哪个观察性，都是如此。

我认为，资源的创建者拥有它，并且应该在价值释放后小心处置。