Xamarin.iOS と Rx で iBeacon を使ってみた

//FindTheMonkeyViewController_after.cs
if (!UserInterfaceIdiomIsPhone)
{
  /* 省略 */
} else
{
  InitPitchAndVolume();
  var man = new CLLocationManager();

  man.StartMonitoringAsObservable(beaconRegion) // 監視開始
  .SelectMany(r =>
    man.RegionEnteredAsObservable() // A:進入の受信
    .Amb(man.RequestStateAsObservable(r) // B:リージョン状態要求
      .Where(e => e.State == CLRegionState.Inside) // 範囲内のみ
      .Select(x => x.Region as CLBeaconRegion) // CLRegion からcast
    .SelectMany(man.StartRangingBeaconsAsObservable) // A/B どちらかを受信したらレンジング開始
      .Where(x => x.Beacons.Length > 0) // ビーコンが1個以上みつかった場合のみ
      .Select(x => x.Beacons [0]) // LINQ の Fisrt() でもOk
      .DistinctUntilChanged(x => x.Proximity) // Proximity が変わった時のみ流す
  .Subscribe((CLBeacon beacon) =>
  {
    // Beacon が見つかった時に行う処理を書く
  });
}

//CLLocationManagerExtensions.cs
public static class CLLocationManagerExtensions
{
  // リージョン監視を開始して、開始通知を IObservable で得る拡張メソッド
  public static IObservable<CLBeaconRegion> StartMonitoringAsObservable(
    this CLLocationManager man, CLBeaconRegion beaconRegion)
  {
    return Observable.Defer(() =>
    {
      var o = Observable.FromEventPattern<CLRegionEventArgs>(
            h => man.DidStartMonitoringForRegion += h, 
            h => man.DidStartMonitoringForRegion -= h)
      .Select(x => x.EventArgs.Region as CLBeaconRegion);
      
      man.StartMonitoring(beaconRegion);          
      return o;
    });
  }
  
  // リージョンへの進入を IObservable で得る拡張メソッド
  public static IObservable<CLBeaconRegion> RegionEnteredAsObservable(
    this CLLocationManager man)
  {
    return Observable.FromEventPattern<CLRegionEventArgs>(
      h => man.RegionEntered += h, h => man.RegionEntered -= h)
        .Select(e => e.EventArgs.Region as CLBeaconRegion);
  }
  
  // リージョンの状態を要求して、結果を IObservable で得る拡張メソッド
  public static IObservable<CLRegionStateDeterminedEventArgs> RequestStateAsObservable(
    this CLLocationManager man, CLBeaconRegion beaconRegion)
  {
    return Observable.Defer<CLRegionStateDeterminedEventArgs>(() => 
    {
      var o = Observable.FromEventPattern<CLRegionStateDeterminedEventArgs>(
      h => man.DidDetermineState += h, h => man.DidDetermineState -= h)
        .Select(e => e.EventArgs);
      
      man.RequestState(beaconRegion);
      return o;
    });
  }
  
  // レンジングを開始してビーコン信号を IObservable で得る拡張メソッド
  public static IObservable<CLRegionBeaconsRangedEventArgs> StartRangingBeaconsAsObservable(
    this CLLocationManager man, CLBeaconRegion beaconRegion)
  {
    return Observable.Defer(() => 
    {
      var o = Observable.FromEventPattern<CLRegionBeaconsRangedEventArgs>(
      h => man.DidRangeBeacons += h, h => man.DidRangeBeacons -= h)
        .Select(e => e.EventArgs);
      
      man.StartRangingBeacons(beaconRegion);
      return o;
    });
  }
}