Working observer pattern test

Author: MystikalPooka

Assets/Scripts/AI/BehaviorManager.cs

@@ -26,7 +26,7 @@ public class BehaviorManager : MonoBehaviour
         /// </summary>
         [SerializeField]
         [Description("Seconds between every tick. At 0 this will tick every frame")]
-        public float SecondsBetweenTicks = 0.1f;
+        public double SecondsBetweenTicks = 0.1f;
 
         /// <summary>
         /// Number of times to tick the full trees. Set to a negative number to make an infinitely running behavior tree.
@@ -78,33 +78,10 @@ public void Reinitialize()
         /// <returns></returns>
         IEnumerator Start()
         {
-            WaitForSeconds wfs = new WaitForSeconds(SecondsBetweenTicks);
-
-            Debug.Log("Starting ticks on Runner: \n\t" + Runner.ToString());
-            var behaviors = Observable.EveryUpdate().DoOnSubscribe(() => Debug.Log("Subscribed!!!")).Subscribe().AddTo(this);
-
-            
-            Runner.ObserveEveryValueChanged(x => x.CurrentState).Subscribe(x => Debug.Log(x));
-            
-
-            while(TimesToTick > 0)
-            {
-                Observable.FromCoroutine(() => Runner.Tick()).Subscribe(xr => Debug.Log("Subscribed to " + xr), xd => Debug.Log("Destroyed " + xd)).AddTo(this);
-                --TimesToTick;
-                yield return wfs;
-            }
-                
-
-
-            yield return null;
-
-            //yield return StartCoroutine(Runner.Tick(wfs));
-            //if (TimesToTick > 0) --TimesToTick;
-
-            
-
-            //Debug.Log("All Coroutines Should be DONE now! Ending all to make sure....");
-            StopAllCoroutines();
+            while(TimesToTick-- > 0)
+                yield return Runner.Tick()
+                                   .ToObservable()
+                                   .Subscribe(xr => Debug.Log("OnNxt called " + xr), xd => Debug.Log("Destroyed " + xd)).AddTo(this);
         }
 
         /// <summary>

Assets/Scripts/AI/BehaviorTreeElement.cs

@@ -2,6 +2,7 @@
 using System;
 using System.Collections;
 using System.Collections.Generic;
+using System.Linq;
 using UniRx;
 using UnityEngine;
 
@@ -53,14 +54,30 @@ public BehaviorTreeElement(string name, int depth, int id)
         [Newtonsoft.Json.JsonIgnore]
         public BehaviorState CurrentState;
 
+        public bool Initialized = false;
         public virtual IEnumerator Tick(WaitForSeconds delayStart = null)
         {
+            if (!Initialized) Initialize();
             if (delayStart != null)
             {
                 yield return delayStart;
             }
         }
 
+        public virtual void Initialize()
+        {
+            var allChildrenToRun = from x in Children
+                                   select x as BehaviorTreeElement;
+
+            foreach(var ch in allChildrenToRun)
+            {
+                ch.ObserveEveryValueChanged(x => x.CurrentState).Subscribe(x => Debug.Log(ElementType + " state changed: " + x));
+            }
+
+            Initialized = true;
+        }
+
+
         public override string ToString()
         {
             var depthPad = "";

Assets/Scripts/AI/BehaviorTreeManagerAsset.cs

@@ -12,7 +12,7 @@ namespace Assets.Scripts.AI
     public class BehaviorTreeManagerAsset : ScriptableObject
     {
         public int TimesToTick;
-        public float SecondsBetweenTicks = 0.1f;
+        public double SecondsBetweenTicks = 10;
 
         public string RunnerElementsJSON;
     }

Assets/Scripts/AI/Components/ParallelRunner.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections;
 using System.ComponentModel;
+using UniRx;
 using UnityEngine;
 
 namespace Assets.Scripts.AI.Components
@@ -30,7 +31,7 @@ public ParallelRunner(string name, int depth, int id)
 
         public override IEnumerator Tick(WaitForSeconds delayStart = null)
         {
-            yield return delayStart;
+            base.Tick().ToObservable().Subscribe(xb => Debug.Log("Subscribed to ParallelRunner at start (base.tick()"));
             CurrentState = (BehaviorState.Running);
             if (Children == null || Children.Count <=0)
             {

Assets/Scripts/AI/Components/Selector.cs

@@ -1,6 +1,9 @@
 using System;
 using System.Collections;
 using System.ComponentModel;
+using System.Linq;
+using UniRx;
+using UnityEngine;
 
 namespace Assets.Scripts.AI.Components
 {
@@ -18,9 +21,9 @@ public Selector(string name, int depth, int id)
 
         public override IEnumerator Tick(UnityEngine.WaitForSeconds delayStart = null)
         {
-            base.Tick();
-            UnityEngine.Debug.LogError("Selector START");
-            
+            base.Tick().ToObservable().Subscribe(xb => Debug.Log("Subscribed to Selector at start (base.tick()"));
+
+
             CurrentState = (BehaviorState.Running);
             foreach (BehaviorTreeElement behavior in Children)
             {
@@ -37,12 +40,11 @@ public override IEnumerator Tick(UnityEngine.WaitForSeconds delayStart = null)
                         yield break;
                     }
                 }
-                UnityEngine.Debug.LogError("Selector is fail");
+                Debug.LogError("Selector is fail");
             }
             //if it gets here, it went through all subbehaviors and had no successes
             CurrentState = BehaviorState.Fail;
             yield break;
         }
-
     } 
 }