convert the rest

Author: Todd Berman

ReactiveUI.Platforms/Cocoa/ReactiveCollectionViewCell.cs

@@ -18,7 +18,7 @@
 
 namespace ReactiveUI.Cocoa
 {
-    public abstract class ReactiveCollectionViewCell : UICollectionViewCell, IReactiveNotifyPropertyChanged, IHandleObservableErrors
+    public abstract class ReactiveCollectionViewCell : UICollectionViewCell, IReactiveNotifyPropertyChanged, IHandleObservableErrors, IReactiveObjectExtension
     {
         public ReactiveCollectionViewCell(IntPtr handle) : base (handle) { setupRxObj(); }
         public ReactiveCollectionViewCell(NSObjectFlag t) : base (t) { setupRxObj(); }
@@ -29,53 +29,49 @@ public abstract class ReactiveCollectionViewCell : UICollectionViewCell, IReacti
         [field:IgnoreDataMember]
         public event PropertyChangingEventHandler PropertyChanging;
 
+        void IReactiveObjectExtension.RaisePropertyChanging(PropertyChangingEventArgs args) {
+            var handler = PropertyChanging;
+            if (handler != null) {
+                handler(this, args);
+            }
+        }
+
         [field:IgnoreDataMember]
         public event PropertyChangedEventHandler PropertyChanged;
 
+        void IReactiveObjectExtension.RaisePropertyChanged(PropertyChangedEventArgs args) {
+            var handler = PropertyChanged;
+            if (handler != null) {
+                handler(this, args);
+            }
+        }
+
         /// <summary>
         /// Represents an Observable that fires *before* a property is about to
         /// be changed.         
         /// </summary>
         [IgnoreDataMember]
         public IObservable<IObservedChange<object, object>> Changing {
-            get { return changingSubject; }
+            get { return this.getChangingObservable(); }
         }
 
         /// <summary>
         /// Represents an Observable that fires *after* a property has changed.
         /// </summary>
         [IgnoreDataMember]
         public IObservable<IObservedChange<object, object>> Changed {
-            get { return changedSubject; }
+            get { return this.getChangedObservable(); }
         }
 
         [IgnoreDataMember]
-        protected Lazy<PropertyInfo[]> allPublicProperties;
-
-        [IgnoreDataMember]
-        Subject<IObservedChange<object, object>> changingSubject;
-
-        [IgnoreDataMember]
-        Subject<IObservedChange<object, object>> changedSubject;
-
-        [IgnoreDataMember]
-        long changeNotificationsSuppressed = 0;
-
-        [IgnoreDataMember] 
-        readonly ScheduledSubject<Exception> thrownExceptions = new ScheduledSubject<Exception>(Scheduler.Immediate, RxApp.DefaultExceptionHandler);
-
-        [IgnoreDataMember]
-        public IObservable<Exception> ThrownExceptions { get { return thrownExceptions; } }
+        public IObservable<Exception> ThrownExceptions { get { return this.getThrownExceptionsObservable(); } }
 
         [OnDeserialized]
         void setupRxObj(StreamingContext sc) { setupRxObj(); }
 
         void setupRxObj()
         {
-            changingSubject = new Subject<IObservedChange<object, object>>();
-            changedSubject = new Subject<IObservedChange<object, object>>();
-
-            allPublicProperties = new Lazy<PropertyInfo[]>(() => GetType().GetProperties(BindingFlags.Public | BindingFlags.Instance).ToArray());
+            this.setupReactiveExtension();
         }
 
         /// <summary>
@@ -87,123 +83,7 @@ void setupRxObj()
         /// notifications.</returns>
         public IDisposable SuppressChangeNotifications()
         {
-            Interlocked.Increment(ref changeNotificationsSuppressed);
-            return Disposable.Create(() => Interlocked.Decrement(ref changeNotificationsSuppressed));
-        }
-
-        protected internal void raisePropertyChanging(string propertyName)
-        {
-            Contract.Requires(propertyName != null);
-
-            if (!areChangeNotificationsEnabled || changingSubject == null)
-                return;
-
-            var handler = this.PropertyChanging;
-            if (handler != null) {
-                var e = new PropertyChangingEventArgs(propertyName);
-                handler(this, e);
-            }
-
-            notifyObservable(new ObservedChange<object, object>() {
-                PropertyName = propertyName, Sender = this, Value = null
-            }, changingSubject);
-        }
-
-        protected internal void raisePropertyChanged(string propertyName)
-        {
-            Contract.Requires(propertyName != null);
-
-            this.Log().Debug("{0:X}.{1} changed", this.GetHashCode(), propertyName);
-
-            if (!areChangeNotificationsEnabled || changedSubject == null) {
-                this.Log().Debug("Suppressed change");
-                return;
-            }
-
-            var handler = this.PropertyChanged;
-            if (handler != null) {
-                var e = new PropertyChangedEventArgs(propertyName);
-                handler(this, e);
-            }
-
-            notifyObservable(new ObservedChange<object, object>() {
-                PropertyName = propertyName, Sender = this, Value = null
-            }, changedSubject);
-        }
-
-        protected bool areChangeNotificationsEnabled {
-            get {
-                return (Interlocked.Read(ref changeNotificationsSuppressed) == 0);
-            }
-        }
-
-        internal void notifyObservable<T>(T item, Subject<T> subject)
-        {
-            try {
-                subject.OnNext(item);
-            } catch (Exception ex) {
-                this.Log().ErrorException("ReactiveObject Subscriber threw exception", ex);
-                thrownExceptions.OnNext(ex);
-            }
-        }
-
-        /// <summary>
-        /// RaiseAndSetIfChanged fully implements a Setter for a read-write
-        /// property on a ReactiveObject, using CallerMemberName to raise the notification
-        /// and the ref to the backing field to set the property.
-        /// </summary>
-        /// <typeparam name="TObj">The type of the This.</typeparam>
-        /// <typeparam name="TRet">The type of the return value.</typeparam>
-        /// <param name="This">The <see cref="ReactiveObject"/> raising the notification.</param>
-        /// <param name="backingField">A Reference to the backing field for this
-        /// property.</param>
-        /// <param name="newValue">The new value.</param>
-        /// <param name="propertyName">The name of the property, usually 
-        /// automatically provided through the CallerMemberName attribute.</param>
-        /// <returns>The newly set value, normally discarded.</returns>
-        public TRet RaiseAndSetIfChanged<TRet>(
-            ref TRet backingField,
-            TRet newValue,
-            [CallerMemberName] string propertyName = null)
-        {
-            Contract.Requires(propertyName != null);
-
-            if (EqualityComparer<TRet>.Default.Equals(backingField, newValue)) {
-                return newValue;
-            }
-
-            raisePropertyChanging(propertyName);
-            backingField = newValue;
-            raisePropertyChanged(propertyName);
-            return newValue;
-        }
-
-        /// <summary>
-        /// Use this method in your ReactiveObject classes when creating custom
-        /// properties where raiseAndSetIfChanged doesn't suffice.
-        /// </summary>
-        /// <param name="This">The instance of ReactiveObject on which the property has changed.</param>
-        /// <param name="propertyName">
-        /// A string representing the name of the property that has been changed.
-        /// Leave <c>null</c> to let the runtime set to caller member name.
-        /// </param>
-        public void RaisePropertyChanged([CallerMemberName] string propertyName = null)
-        {
-            raisePropertyChanged(propertyName);
-        }
-
-        /// <summary>
-        /// Use this method in your ReactiveObject classes when creating custom
-        /// properties where raiseAndSetIfChanged doesn't suffice.
-        /// </summary>
-        /// <param name="This">The instance of ReactiveObject on which the property has changed.</param>
-        /// <param name="propertyName">
-        /// A string representing the name of the property that has been changed.
-        /// Leave <c>null</c> to let the runtime set to caller member name.
-        /// </param>
-        public void RaisePropertyChanging([CallerMemberName] string propertyName = null)
-        {
-            raisePropertyChanging(propertyName);
+            return this.suppressChangeNotifications();
         }
     }
 }