Renaming a file.

AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/AsyncLockObserver.cs → AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/AsyncQueueLockAsyncObserver.cs

@@ -7,12 +7,12 @@ using System.Threading.Tasks;
 
 namespace System.Reactive
 {
-    internal sealed class AsyncLockObserver<T> : AsyncObserverBase<T>
+    internal sealed class AsyncQueueLockAsyncObserver<T> : AsyncObserverBase<T>
     {
         private readonly AsyncQueueLock _gate = new AsyncQueueLock();
         private readonly IAsyncObserver<T> _observer;
 
-        public AsyncLockObserver(IAsyncObserver<T> observer)
+        public AsyncQueueLockAsyncObserver(IAsyncObserver<T> observer)
         {
             _observer = observer;
         }

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

@@ -619,7 +619,7 @@ namespace System.Reactive.Linq
                                         if (nullGroup == null)
                                         {
                                             var subject = new SequentialSimpleAsyncSubject<TElement>();
-                                            nullGroup = AsyncSubject.Create(new AsyncLockObserver<TElement>(subject), subject);
+                                            nullGroup = AsyncSubject.Create(new AsyncQueueLockAsyncObserver<TElement>(subject), subject);
                                             shouldEmit = true;
                                         }
                                     }
@@ -633,7 +633,7 @@ namespace System.Reactive.Linq
                                         if (!groups.TryGetValue(key, out group))
                                         {
                                             var subject = new SequentialSimpleAsyncSubject<TElement>();
-                                            group = AsyncSubject.Create(new AsyncLockObserver<TElement>(subject), subject);
+                                            group = AsyncSubject.Create(new AsyncQueueLockAsyncObserver<TElement>(subject), subject);
 
                                             if (groups.TryAdd(key, group))
                                             {