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可以被任何客户端使用。在您的特定情况下，谁决定何时以及由谁处置资源？最坏的情况是，一个客户端会在允许另一个客户端使用实例之前释放该实例。在我看来，处置资源根本不是消费者的责任。无论订阅哪个可观察量，都是如此。

在我看来，资源的创建者拥有它，并且应该在发出值后注意处理它。