Using SubscribeSafeAsync in a few more places.

AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/Buffer.cs

@@ -683,7 +683,7 @@ namespace System.Reactive.Linq
                             CloseBufferAsync
                         );
 
-                    var closingSubscriptionInner = await closing.SubscribeAsync(closingObserver).ConfigureAwait(false);
+                    var closingSubscriptionInner = await closing.SubscribeSafeAsync(closingObserver).ConfigureAwait(false);
                     await closingSubscription.AssignAsync(closingSubscriptionInner).ConfigureAwait(false);
                 }
 

AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/GroupBy.cs

@@ -225,7 +225,7 @@ namespace System.Reactive.Linq
 
             var (sink, subscription) = createObserver(observer, d);
 
-            var inner = await source.SubscribeAsync(sink).ConfigureAwait(false);
+            var inner = await source.SubscribeSafeAsync(sink).ConfigureAwait(false);
             await d.AssignAsync(inner).ConfigureAwait(false);
 
             return subscription;

AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/GroupByUntil.cs

@@ -259,7 +259,7 @@ namespace System.Reactive.Linq
 
             var (sink, subscription) = await createObserver(observer, d).ConfigureAwait(false);
 
-            var inner = await source.SubscribeAsync(sink).ConfigureAwait(false);
+            var inner = await source.SubscribeSafeAsync(sink).ConfigureAwait(false);
             await d.AssignAsync(inner).ConfigureAwait(false);
 
             return subscription;

AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/Repeat.cs

@@ -136,7 +136,7 @@ namespace System.Reactive.Linq
             {
                 var (sink, inner) = Concat(observer, Repeat(source).GetEnumerator());
 
-                var subscription = await source.SubscribeAsync(sink).ConfigureAwait(false);
+                var subscription = await source.SubscribeSafeAsync(sink).ConfigureAwait(false);
 
                 return StableCompositeAsyncDisposable.Create(subscription, inner);
             }
@@ -157,7 +157,7 @@ namespace System.Reactive.Linq
             {
                 var (sink, inner) = Concat(observer, Enumerable.Repeat(source, repeatCount).GetEnumerator());
 
-                var subscription = await source.SubscribeAsync(sink).ConfigureAwait(false);
+                var subscription = await source.SubscribeSafeAsync(sink).ConfigureAwait(false);
 
                 return StableCompositeAsyncDisposable.Create(subscription, inner);
             }

AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/Window.cs

@@ -162,7 +162,7 @@ namespace System.Reactive.Linq
 
             var (sink, subscription) = createObserver(observer, d);
 
-            var inner = await source.SubscribeAsync(sink).ConfigureAwait(false);
+            var inner = await source.SubscribeSafeAsync(sink).ConfigureAwait(false);
             await d.AssignAsync(inner).ConfigureAwait(false);
 
             return subscription;
@@ -174,7 +174,7 @@ namespace System.Reactive.Linq
 
             var (sink, subscription) = await createObserverAsync(observer, d).ConfigureAwait(false);
 
-            var inner = await source.SubscribeAsync(sink).ConfigureAwait(false);
+            var inner = await source.SubscribeSafeAsync(sink).ConfigureAwait(false);
             await d.AssignAsync(inner).ConfigureAwait(false);
 
             return subscription;
@@ -768,7 +768,7 @@ namespace System.Reactive.Linq
                         CloseWindowAsync
                     );
 
-                var closingSubscriptionInner = await closing.SubscribeAsync(closingObserver).ConfigureAwait(false);
+                var closingSubscriptionInner = await closing.SubscribeSafeAsync(closingObserver).ConfigureAwait(false);
                 await closingSubscription.AssignAsync(closingSubscriptionInner).ConfigureAwait(false);
             }