将 Android 生命周期回调转换为 Reactive Observable

Question

如何将 Android 生命周期回调转换为 RX Observable？

例如，onNewIntent。我可以让我的 Activity 本身成为一个自定义的 Observable，为 onNewIntent 中的一群观察者调用 onNext——但这感觉很恶心。如果可以的话，我宁愿不实现自制的 Observable，这样就不需要搞乱多线程等。

namespace ...
{
    using ...

    /// <summary>
    /// Main application activity.
    /// </summary>
    [Activity(...)]
    public class MainActivity : Xamarin.Forms.Platform.Android.FormsAppCompatActivity, IObservable<Intent>
    {
        private List<IObserver<Intent>> observers;

        ...

        /// <inheritdoc/>
        public IDisposable Subscribe(IObserver<Intent> observer)
        {
            this.observers.Add(observer);
            return new Unsubscriber(this.observers, observer);
        }

        /// <inheritdoc/>
        protected override void OnNewIntent(Intent intent)
        {
            foreach (var observer in this.observers)
            {
                observer.OnNext(intent);
            }
        }

        private class Unsubscriber : IDisposable
        {
            private List<IObserver<Intent>> observers;
            private IObserver<Intent> observer;
            private bool disposedValue;

            public Unsubscriber(
                List<IObserver<Intent>> observers,
                IObserver<Intent> observer)
            {
                this.observers = observers;
                this.observer = observer;
            }

            public void Dispose()
            {
                // Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
                this.Dispose(disposing: true);
                GC.SuppressFinalize(this);
            }

            protected virtual void Dispose(bool disposing)
            {
                if (!this.disposedValue)
                {
                    // dispose managed state (managed objects)
                    if (disposing &&
                        this.observer != null &&
                        this.observers.Contains(this.observer))
                    {
                        this.observers.Remove(this.observer);
                    }

                    // set large fields to null
                    this.observers = null;
                    this.observer = null;

                    this.disposedValue = true;
                }
            }
        }
    }
}

如果有类似 NewIntent 的事件，这将是一个更简单的问题 - 有事件、委托等的创建操作符。但这些都与事件外部的事件一起工作 - 有一些东西就像 onNewIntent 覆盖实现一样，我已经在事件中（在 monad 中？）。所以我不知道如何反转它。

Answer 1

我想出了一个解决办法。不确定它是最优雅的，但它基本上涉及创建一个我在处理回调时引发的附加事件。然后就可以快速前往 FromEventPattern，嘿，转瞬即逝！可观察的事件数据。很高兴听到其他人是否有任何替代方法，但这似乎有效。

namespace ...
{
    using ...

    /// <summary>
    /// Main application activity.
    /// </summary>
    [Activity(...)]
    public class MainActivity : Xamarin.Forms.Platform.Android.FormsAppCompatActivity, IWithNewIntentObservable
    {
        private event EventHandler<Intent> NewIntent;

        /// <inheritdoc/>
        public IObservable<Intent> NewIntentObservable { get; private set; }

        ...

        /// <inheritdoc/>
        protected override void OnCreate(Bundle savedInstanceState)
        {
            base.OnCreate(savedInstanceState);

            ...

            this.NewIntentObservable = Observable.FromEventPattern<Intent>(
                h => this.NewIntent += h,
                h => this.NewIntent -= h).Select(e => e.EventArgs);
        }

        /// <inheritdoc/>
        protected override void OnNewIntent(Intent intent)
        {
            this.NewIntent?.Invoke(this, intent);
        }
    }
}

将 Android 生命周期回调转换为 Reactive Observable

Convert Android Lifecycle Callback to Reactive Observable

android

xamarin

callback

observable

reactive