System.Reactive:实现IObservable<T>

Question

我需要创建一个自定义的IObservable。我在那里读了一点，我最终认为我不应该直接实现IObservable<T>。

我注意到有一个ObservableBase<T>。这是一个抽象类，所以我需要实现抽象方法：

public class Store<TState> : ObservableBase<TState>, IObserver<IAction>
{
    public void OnCompleted()
    {
        throw new NotImplementedException();
    }

    public void OnError(Exception error)
    {
        throw new NotImplementedException();
    }

    public void OnNext(IAction value)
    {
        throw new NotImplementedException();
    }

    protected override IDisposable SubscribeCore(IObserver<TState> observer)
    {
        >>>>>>>>>>>>>>>>>******<<<<<<<<<<<<<<<<<<<<<<<
        throw new NotImplementedException();
    }
}

我应该如何实现这个方法？