|
@@ -422,8 +422,11 @@ namespace System.Reactive.Subjects
|
|
|
lock (_gate)
|
|
lock (_gate)
|
|
|
{
|
|
{
|
|
|
observer.Dispose();
|
|
observer.Dispose();
|
|
|
|
|
+
|
|
|
if (!_isDisposed)
|
|
if (!_isDisposed)
|
|
|
|
|
+ {
|
|
|
_observers = _observers.Remove(observer);
|
|
_observers = _observers.Remove(observer);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -693,6 +696,7 @@ namespace System.Reactive.Subjects
|
|
|
{
|
|
{
|
|
|
Dispose(true);
|
|
Dispose(true);
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
protected virtual void Dispose(bool disposing)
|
|
protected virtual void Dispose(bool disposing)
|
|
|
{
|
|
{
|
|
|
lock (_gate)
|
|
lock (_gate)
|