Android Broadcast Receivers to RX Observables

gistfile1.txt

public static class AndroidObservables
    {

        public static IObservable<Intent> WhenIntentReceived(string intentAction)
        {
            return Observable.Create<Intent>(ob =>
            {
                var filter = new IntentFilter();
                filter.AddAction(intentAction);
                var receiver = new ObservableBroadcastReceiver
                {
                    OnEvent = ob.OnNext
                };
                Application.Context.RegisterReceiver(receiver, filter);
                return () => Application.Context.UnregisterReceiver(receiver);
            });
        }
    }


    public class ObservableBroadcastReceiver : BroadcastReceiver
    {
        public Action<Intent> OnEvent { get; set; }

        public override void OnReceive(Context context, Intent intent)
        {
            this.OnEvent?.Invoke(intent);
        }
    }
    
    
    // EXAMPLES
          public static IObservable<BluetoothDevice> WhenDeviceNameChanged()
        {
            return WhenDeviceEventReceived(BluetoothDevice.ActionNameChanged);
        }


        public static IObservable<BluetoothDevice> WhenDeviceEventReceived(string action)
        {
            return AndroidObservables
                .WhenIntentReceived(action)
                .Select(intent =>
                {
                    var device = (BluetoothDevice)intent.GetParcelableExtra(BluetoothDevice.ExtraDevice);
                    return device;
                });
        }