UnityInputSystemR3ObservableTriggerExtensions

InputSystemObservableTriggerExtensions.cs

using UnityEngine.InputSystem;
using R3;

namespace R3.Triggers
{
    public static class InputSystemObservableTriggerExtensions
    {
        public static Observable<InputAction.CallbackContext> AsObservable(this InputAction action) =>
            Observable.FromEvent<InputAction.CallbackContext>(
                h =>
                {
                    action.performed += h;
                    action.canceled += h;
                },
                h =>
                {
                    action.performed -= h;
                    action.canceled -= h;
                });

        public static Observable<Unit> IsPressedAsObservable(this InputAction action) =>
            Observable.EveryUpdate()
                .Where(_ => action.IsPressed())
                .Select(_ => Unit.Default);
    }
}