Fix InvalidOperationException when combining ReplaySubject and Take()…

… (issue neuecc#292)

Assets/Plugins/UniRx/Scripts/Subjects/ReplaySubject.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using UniRx.InternalUtil;
 
 namespace UniRx
@@ -167,7 +168,7 @@ public IDisposable Subscribe(IObserver<T> observer)
 
                 ex = lastError;
                 Trim();
-                foreach (var item in queue)
+                foreach (var item in queue.ToList())
                 {
                     observer.OnNext(item.Value);
                 }

Assets/Scripts/UnityTests/Rx/SubjectTest.cs

@@ -477,5 +477,39 @@ public void ReplaySubjectWindowReplay()
             subject.Subscribe(x => onNext.Add(x), x => exception.Add(x), () => onCompletedCallCount++);
             onNext.Is(10000, 2, 20);
         }
+
+        ///<Summary>
+        /// Regression test for previous InvalidOperationException
+        /// UniRx issue <a href="https://github.com/neuecc/UniRx/issues/292">#292</a>
+        ///</Summary>
+        [Test]
+        public void ReplaySubject_Take_GivesCorrectResult()
+        {
+            var subject = new ReplaySubject<int>(1);
+
+            var onNext = new List<int>();
+
+            subject.OnNext(1);
+
+            var _ = subject
+                .Take(1)
+                .Do(subject.OnNext)
+                .Subscribe(onNext.Add);
+
+            onNext.Is(1);
+
+            _.Dispose();
+            onNext.Clear();
+
+            subject.OnNext(2);
+            subject.OnNext(3);
+
+            _ = subject
+                .Take(1)
+                .Do(subject.OnNext)
+                .Subscribe(onNext.Add);
+
+            onNext.Is(3);
+        }
     }
 }