Merge branch 'hotfix/1.0.2'

Author: Arvtesh

CHANGELOG.md

@@ -3,6 +3,12 @@ All notable changes to this project will be documented in this file.
 
 The format is based on [Keep a Changelog](http://keepachangelog.com/); this project adheres to [Semantic Versioning](http://semver.org/).
 
+-----------------------
+## [1.0.2] - 2019.05.19
+
+### Fixed
+- Fixed `AsyncUtility.FrameUpdate()` not scheduling callbacks as expected.
+
 -----------------------
 ## [1.0.1] - 2019.04.09
 

src/UnityFx.Async.AssetStore/Assets/Plugins/UnityFx.Async/Scripts/AsyncUtility.cs

@@ -492,14 +492,16 @@ private sealed class AsyncUtilityBehaviour : MonoBehaviour
 		{
 			#region data
 
+			private WaitForEndOfFrame _eof;
+			private Coroutine _eofCoroutine;
+
 			private Dictionary<object, Action> _ops;
 			private List<KeyValuePair<object, Action>> _opsToRemove;
 
 			private AsyncUpdateSource _updateSource;
 			private AsyncUpdateSource _lateUpdateSource;
 			private AsyncUpdateSource _fixedUpdateSource;
 			private AsyncUpdateSource _eofUpdateSource;
-			private WaitForEndOfFrame _eof;
 
 #if NET_4_6 || NET_STANDARD_2_0
 
@@ -567,8 +569,11 @@ public IAsyncUpdateSource EofUpdateSource
 					if (_eofUpdateSource == null)
 					{
 						_eofUpdateSource = new AsyncUpdateSource();
-						_eof = new WaitForEndOfFrame();
-						StartCoroutine(EofEnumerator());
+					}
+
+					if (_eofCoroutine == null)
+					{
+						_eofCoroutine = StartCoroutine(EofEnumerator());
 					}
 
 					return _eofUpdateSource;
@@ -603,6 +608,12 @@ public void AddFrameCallback(Action callback, FrameTiming timing)
 						break;
 
 					case FrameTiming.EndOfFrame:
+
+						if (_eofCoroutine == null)
+						{
+							_eofCoroutine = StartCoroutine(EofEnumerator());
+						}
+
 						AddFrameCallback(ref _eofUpdateActions, callback);
 						break;
 				}
@@ -612,6 +623,11 @@ public void AddFrameCallback(Action callback, FrameTiming timing)
 
 			#region MonoBehavoiur
 
+			private void Awake()
+			{
+				_eof = new WaitForEndOfFrame();
+			}
+
 			private void Update()
 			{
 				if (_ops != null && _ops.Count > 0)
@@ -840,7 +856,9 @@ private IEnumerator EofEnumerator()
 				{
 					InvokeFrameCallbacks(_eofUpdateActions, this);
 				}
-			}
+
+				_eofCoroutine = null;
+            }
 
 			#endregion
 		}