subject.Dispose与subject.OnCompleted

如何解决subject.Dispose与subject.OnCompleted

.dispose()上的.OnCompleted()和Subject调用之间有什么区别？

通常，当代码中的任何地方不再有用时，我通常会取消订阅以停止收听可观察的内容并完成一个主题，

解决方法

通常，我处置订阅以停止在代码上的任何地方不再有用时停止监听可观察对象并完成主题

我认为你有那些倒退。我对rx.net并不熟悉，但是我确实知道IDisposable和Observable模式。当对象完全使用完后，IDisposable可用于从对象释放资源，它不再有用。 OnCompleted用于观察完成后（提供者已完成发送通知），即使对象可能还有其他用途。

,

在主题上调用.OnCompleted()和Subject<int> subject = new Subject<int>(); IObservable<int[]> query = subject.ToArray(); IDisposable subscription = query .Subscribe(xs => Console.WriteLine(String.Concat(xs))); subject.OnNext(1); subject.OnNext(2); 之间存在非常重要的语义差异。

考虑以下代码：

subject.OnCompleted()

如果我随后打电话给12，我会把subject.Dispose()写入控制台。但是，如果我打电话给.ToArray()，那么什么也没打印。

某些运算符，例如我的示例代码中的.OnCompleted()，期望subject调用产生任何值。

重要的是要了解您正在library(shiny) library(rhandsontable) vt <- mtcars modrows <- c(3,6,9) modtext <- LETTERS[1:3] vttooltips <- matrix(ncol = ncol(vt),nrow = nrow(vt)) vttooltips[modrows,2] <- modtext shinyApp( ui = fluidPage( rHandsontableOutput('table') ),server = function(input,output) { tbl <- rhandsontable(vt,readOnly=TRUE,comments = vttooltips) output$table <- renderRHandsontable(tbl) } ) 上执行哪些查询，以了解如何正确结束它-在某些情况下，两种方法均有效。

不过，我觉得您在处理订阅和完成主题方面做得正确。

,

根据Subject<T>.Dispose方法的documentation：

释放Subject<T>类的当前实例使用的所有资源，并取消订阅所有观察者。

似乎在处置Subject之后尝试对ObjectDisposedException执行任何操作都会导致Subscribe。例如，您不能Subject到已处置的Subject。处置OnCompleted时处于活动状态的所有订阅也将被处置，并且未订阅的观察者将不接收OnCompleted通知。

相反，通过调用OnCompleted方法完成的主题仍然可以随时订阅，在这种情况下，订阅的观察者将立即收到OnNext通知。当然，如果完成的主题是诸如ReplaySubject之类的缓冲类型之一，那么观察者将在最终的OnCompleted之前收到许多Dispose通知。

我个人考虑将ReplaySubject调用到将要丢弃的Dispose上，以加速对其内部缓冲区使用的RAM的恢复。我不确定这是否会有所作为，因为通常func zero(sample interface{}) interface{} { return reflect.Zero(reflect.TypeOf(sample)) } 应该释放非托管资源，并且缓冲区使用的内存很可能是托管的。