// 2014 - Pixelnest Studio using System; using System.Collections; using UnityEngine; using UniRx; namespace KairoEngine.Core { /// Ready to use timers for coroutines public class Timer { /// Simple timer, no reference, wait and then execute something /// /// /// public static IEnumerator Start(float duration, Action callback) { return Start(duration, false, callback); } /// Simple timer, no reference, wait and then execute something /// /// /// /// public static IEnumerator Start(float duration, bool repeat, Action callback) { do { yield return new WaitForSeconds(duration); if (callback != null) callback(); } while (repeat); } public static IEnumerator StartRealtime(float time, System.Action callback) { float start = Time.realtimeSinceStartup; while (Time.realtimeSinceStartup < start + time) { yield return null; } if (callback != null) callback(); } public static IEnumerator NextFrame(Action callback) { yield return new WaitForEndOfFrame(); if (callback != null) callback(); } /// /// Executes a function after a certain time has passed, based on Time.scale. /// /// In miliseconds /// A function to be executed /// A CompositeDisposable which can be used to cancel the timer public static CompositeDisposable Execute(float time, Action action) { var timer = Observable.Timer(TimeSpan.FromMilliseconds(time)); CompositeDisposable cancel = new CompositeDisposable(); timer.Subscribe(xs => { action(); cancel.Dispose(); }).AddTo(cancel); return cancel; } /// /// Executes a function after a certain real time has passed. /// /// In miliseconds /// A function to be executed /// A CompositeDisposable which can be used to cancel the timer public static CompositeDisposable ExecuteRealTime(float time, Action action) { var timer = Observable.Timer(TimeSpan.FromMilliseconds(time), Scheduler.MainThreadIgnoreTimeScale); CompositeDisposable cancel = new CompositeDisposable(); timer.Subscribe(xs => { action(); cancel.Dispose(); }).AddTo(cancel); return cancel; } /// /// Executes a function after a certain real time has passed. /// /// In miliseconds /// A function to be executed /// A CompositeDisposable which can be used to cancel the timer public static void ExecuteRealTimeNotDisposable(float time, Action action) { var timer = Observable.Timer(TimeSpan.FromMilliseconds(time), Scheduler.MainThreadIgnoreTimeScale); CompositeDisposable cancel = new CompositeDisposable(); timer.Subscribe(xs => { action(); cancel.Dispose(); }).AddTo(cancel); } } }