Merge pull request #296 from TORISOUP/fix_sample_with_observable

Change "Sample" operator behavior.
neuecc · Jul 16, 2018 · b04640a · b04640a
2 parents 4911076 + 1b3437e
commit b04640a
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/Assets/Plugins/UniRx/Scripts/Operators/Sample.cs b/Assets/Plugins/UniRx/Scripts/Operators/Sample.cs
@@ -201,6 +201,18 @@ public SampleTick(Sample parent)
 
                 public void OnCompleted()
                 {
+                    lock (parent.gate)
+                    {
+                        if (parent.isUpdated)
+                        {
+                            parent.isUpdated = false;
+                            parent.observer.OnNext(parent.latestValue);
+                        }
+                        if (parent.isCompleted)
+                        {
+                            try { parent.observer.OnCompleted(); } finally { parent.Dispose(); }
+                        }
+                    }
                 }
 
                 public void OnError(Exception error)