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

Question

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

例如，onNewIntent。我可以让我的Activity本身成为一个自定义的Observable，为onNewIntent中的一群Observators调用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);
}
}
}