Xamarin.Formsでリアクティブプログラミングを試してみる #Xamarin

Reactive Extensionsとかいうのを使ってリアクティブプログラミングとやらに挑んでみる。

リアクティブとかよく分かってないんで正しいアプローチなのか不安。

パッケージ追加

Reactive Extensions (Rx)¹というパッケージを追加²する。

こいつが追加されているとObservableのイベントハンドラをラムダ式としてSubscribeの引数に指定できるようになる。

追加しなかった場合、監視側に IObserve を実装することになり、OnNext/OnError/OnCompleted の各メソッドの実装を強制される。うざい。

パッケージ追加に失敗

Could not install package 'System.Runtime.InteropServices.RuntimeInformation 4.0.0'.

とか言われて、パッケージ追加に失敗した場合は "System.Runtime.InteropServices.RuntimeInformation" を追加したあとに再実行するとうまくいく感じ。

コード

オブザーバーである MainPageViewModel が IObserver を実装していないことに注目。
OnNext/OnError/OnCompleted はメンバ関数ではなく、Subscribe の引数にラムダ式として指定している。

App.xaml.cs

using Xamarin.Forms;
using MyApp.Views;

namespace MyApp
{
    public partial class App : Application
    {
        public App() {
            InitializeComponent();
            MainPage = new MainPage();
        }
    }
}

MainPage.xaml

<?xml version="1.0" encoding="UTF-8"?>
<ContentPage
    xmlns="http://xamarin.com/schemas/2014/forms"
    xmlns:x="http://schemas.microsoft.com/winfx/2009/xaml"
    x:Class="MyApp.Views.MainPage">

    <StackLayout VerticalOptions="Center" HorizontalOptions="Center">
        <Label Text="{Binding Greeting}" HorizontalTextAlignment="Center" />
        <Button Text="Greet" Command="{Binding GreetCommand}" />
        <Button Text="Clear" Command="{Binding ClearCommand}" />
    </StackLayout>

</ContentPage>

MainPage.xaml.cs

using Xamarin.Forms;
using MyApp.ViewModels;

namespace MyApp.Views
{
    public partial class MainPage : ContentPage
    {
        public MainPage() {
            InitializeComponent();
            BindingContext = new MainPageViewModel();
        }
    }
}

MainPageViewModel.cs

using System;
using System.ComponentModel;
using System.Windows.Input;
using System.Reactive.Linq;
using Xamarin.Forms;
using MyApp.Services;

namespace MyApp.ViewModels
{
    public class MainPageViewModel : INotifyPropertyChanged
    {
        public event PropertyChangedEventHandler PropertyChanged;

        public string Greeting { get; set; }

        public ICommand GreetCommand { protected set; get; }
        public ICommand ClearCommand { protected set; get; }

        public MainPageViewModel() {
            Greeting = "...";

            GreetingService service = new GreetingService();

            service.Subscribe(
                value => {
                    System.Diagnostics.Debug.WriteLine("OnNext: " + value);
                    Greeting = value;
                    OnPropertyChanged(nameof(Greeting));
                },
                e => {
                    System.Diagnostics.Debug.WriteLine("OnError: " + e.Message);
                },
                () => {
                    System.Diagnostics.Debug.WriteLine("OnCompleted");
                }
            );

            GreetCommand = new Command(() => {
                service.Greet();
            });

            ClearCommand = new Command(() => {
                Greeting = "...";
                OnPropertyChanged(nameof(Greeting));
            });
        }

        protected void OnPropertyChanged(string propertyName) {
            PropertyChanged(this, new PropertyChangedEventArgs(propertyName));
        }
    }
}

GreetingService.cs

using System;
using System.Reactive.Subjects;

namespace MyApp.Services
{
    public class GreetingService : IObservable<string>
    {
        protected Subject<string> source = new Subject<string>();

        public IDisposable Subscribe(IObserver<string> observer) {
            return source.Subscribe(observer);
        }

        public void Greet() {
            source.OnNext("こんにちわ");
        }
    }
}

結果

Greet ボタン押下で GreetingService がオブザーバーに OnNext で渡した文字列が表示されました。

Rxの使い方ってこれで合ってるんだろうか・・・？

とりあえず以上です。

こちらを参考にしました

http://blog.okazuki.jp/entry/20111101/1320156608
http://blog.xin9le.net/entry/2012/01/15/163827

昔は System.Reactive ではなく、Rx.NET だったらしい。 ↩
PCLだけでなく、各プラットフォーム用プロジェクトにも追加しないとダメっぽい。やはりよくわからん。 ↩