Working Reactive Movement

Author: MystikalPooka

Assets/CameraController.cs

@@ -0,0 +1,23 @@
+using System.Collections;
+using System.Collections.Generic;
+using UnityEngine;
+
+[ExecuteInEditMode]
+public class CameraController : MonoBehaviour
+{
+
+    public GameObject Player;
+    private Vector3 offset;
+
+    void Start()
+    {
+        offset = transform.position - Player.transform.position;
+    }
+
+    // Update is called once per frame
+    void LateUpdate()
+    {
+        transform.position = Player.transform.position + offset;
+
+    }
+}

…TEST/ReactiveBehaviorTreeElement.cs.meta Assets/CameraController.cs.metaAssets/Scripts/AI/ReactiveTEST/ReactiveBehaviorTreeElement.cs.meta renamed to Assets/CameraController.cs.meta Assets/Scripts/AI/ReactiveTEST/ReactiveBehaviorTreeElement.cs.meta renamed to Assets/CameraController.cs.meta

@@ -0,0 +1,21 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using UniRx;
+using UniRx.Triggers;
+using UnityEngine;
+
+public class InputHandler : MonoBehaviour
+{
+    public IObservable<Vector2> Movement { get; private set; }
+
+    private void Awake()
+    {
+        Movement = this.FixedUpdateAsObservable()
+          .Select(_ => {
+              var x = Input.GetAxis("Horizontal");
+              var y = Input.GetAxis("Vertical");
+              return new Vector2(x, y).normalized;
+          });
+    }
+}

Assets/InputHandler.cs

@@ -0,0 +1,29 @@
+using System.Collections;
+using System.Collections.Generic;
+using UniRx;
+using UnityEngine;
+
+public class PlayerController : MonoBehaviour
+{
+    public InputHandler inputs;
+
+    public float walkSpeed = 0.5f;
+    private CharacterController character;
+    // Use this for initialization
+    private void Start()
+    {
+        character = FindObjectOfType<CharacterController>();
+        inputs.Movement
+          .Where(v => v != Vector2.zero)
+          .Subscribe(inputMovement => {
+              var inputVelocity = inputMovement * walkSpeed;
+
+              var playerVelocity =
+            inputVelocity.x * transform.right +
+            inputVelocity.y * transform.forward;
+
+              var distance = playerVelocity * Time.fixedDeltaTime;
+              character.Move(distance);
+          }).AddTo(this);
+    }
+}

Assets/InputHandler.cs.meta

@@ -12,21 +12,24 @@ namespace Assets.Scripts.AI.Components
     /// Returns and is in success state if a child was successful, otherwise returns in fail state
     /// </summary>
     [Serializable]
-    [Description("Runs children in order")]
+    [Description("Runs children in order. Succeeds on first child that succeeds.")]
     public class Selector : BehaviorComponent
     {
         public Selector(string name, int depth, int id) 
             : base(name, depth, id)
         { }
 
-        public override IEnumerator Tick(UnityEngine.WaitForSeconds delayStart = null)
+        public override IEnumerator Tick(WaitForSeconds delayStart = null)
         {
             base.Tick().ToObservable().Subscribe(xb => Debug.Log("Subscribed to Selector at start (base.tick()"));
 
             CurrentState = (BehaviorState.Running);
             foreach (BehaviorTreeElement behavior in Children)
             {
-                yield return BehaviorTreeManager.StartCoroutine(behavior.Tick());
+                yield return behavior.Tick().ToObservable().Subscribe(_ =>
+                {
+
+                });
 
                 if (behavior.CurrentState != BehaviorState.Fail)
                 {

Assets/PlayerController.cs

@@ -14,7 +14,7 @@ public Sequencer(string name, int depth, int id)
         {
         }
 
-        public override IEnumerator Tick(UnityEngine.WaitForSeconds delayStart = null)
+        public override IEnumerator Tick(WaitForSeconds delayStart = null)
         {
             yield return delayStart;
             CurrentState = BehaviorState.Running;

Assets/PlayerController.cs.meta

@@ -22,7 +22,7 @@ public override IEnumerator Tick(WaitForSeconds delayStart = null)
 
             yield return behavior.Tick().ToObservable().Subscribe(_ =>
             {
-                Debug.Log("Inverting " + behavior);
+                Debug.LogError("Inverting " + behavior);
                 switch (behavior.CurrentState)
                 {
                     case BehaviorState.Fail:
@@ -38,11 +38,7 @@ public override IEnumerator Tick(WaitForSeconds delayStart = null)
                         Debug.LogError("Something went wrong in an inverter.");
                         break;
                 }
-            }
-
-                
-                );
-
+            });
         }
     }
 }

Assets/Scripts/AI/Components/Selector.cs

@@ -12,7 +12,7 @@ public BehaviorNode(string name, int depth, int id) : base(name, depth, id)
 
         public override IEnumerator Tick(WaitForSeconds delayStart = null)
         {
-            return base.Tick(delayStart);
+            yield return base.Tick(delayStart);
         }
     }
 }