Merge pull request #77 from omo/onsubscribe

Rename OnSubscribe subclasses to OnSubscribeXx

Author: mttkay

rxandroid/src/main/java/rx/android/content/ContentObservable.java

@@ -102,7 +102,7 @@ public static <T> Observable<T> bindFragment(Object fragment, Observable<T> sour
      * @param filter Selects the Intent broadcasts to be received.
      */
     public static Observable<Intent> fromBroadcast(Context context, IntentFilter filter){
-        return Observable.create(new OperatorBroadcastRegister(context, filter, null, null));
+        return Observable.create(new OnSubscribeBroadcastRegister(context, filter, null, null));
     }
 
     /**
@@ -116,7 +116,7 @@ public static Observable<Intent> fromBroadcast(Context context, IntentFilter fil
      *      the Intent.  If null, the main thread of the process will be used.
      */
     public static Observable<Intent> fromBroadcast(Context context, IntentFilter filter, String broadcastPermission, Handler schedulerHandler){
-        return Observable.create(new OperatorBroadcastRegister(context, filter, broadcastPermission, schedulerHandler));
+        return Observable.create(new OnSubscribeBroadcastRegister(context, filter, broadcastPermission, schedulerHandler));
     }
 
     /**
@@ -126,7 +126,7 @@ public static Observable<Intent> fromBroadcast(Context context, IntentFilter fil
      * @param filter Selects the Intent broadcasts to be received.
      */
     public static Observable<Intent> fromLocalBroadcast(Context context, IntentFilter filter){
-        return Observable.create(new OperatorLocalBroadcastRegister(context, filter));
+        return Observable.create(new OnSubscribeLocalBroadcastRegister(context, filter));
     }
 
     /**
@@ -135,7 +135,7 @@ public static Observable<Intent> fromLocalBroadcast(Context context, IntentFilte
      * Items will be observed on the main Android UI thread
      */
     public static Observable<String> fromSharedPreferencesChanges(SharedPreferences sharedPreferences){
-        return Observable.create(new OperatorSharedPreferenceChange(sharedPreferences));
+        return Observable.create(new OnSubscribeSharedPreferenceChange(sharedPreferences));
     }
 
     private ContentObservable() {

rxandroid/src/main/java/rx/android/content/OperatorBroadcastRegister.java renamed to rxandroid/src/main/java/rx/android/content/OnSubscribeBroadcastRegister.java

@@ -25,14 +25,14 @@
 import rx.functions.Action0;
 import rx.subscriptions.Subscriptions;
 
-class OperatorBroadcastRegister implements Observable.OnSubscribe<Intent> {
+class OnSubscribeBroadcastRegister implements Observable.OnSubscribe<Intent> {
 
     private final Context context;
     private final IntentFilter intentFilter;
     private final String broadcastPermission;
     private final Handler schedulerHandler;
 
-    public OperatorBroadcastRegister(Context context, IntentFilter intentFilter, String broadcastPermission, Handler schedulerHandler) {
+    public OnSubscribeBroadcastRegister(Context context, IntentFilter intentFilter, String broadcastPermission, Handler schedulerHandler) {
         this.context = context;
         this.intentFilter = intentFilter;
         this.broadcastPermission = broadcastPermission;

rxandroid/src/main/java/rx/android/content/OperatorLocalBroadcastRegister.java renamed to rxandroid/src/main/java/rx/android/content/OnSubscribeLocalBroadcastRegister.java

@@ -25,12 +25,12 @@
 import rx.functions.Action0;
 import rx.subscriptions.Subscriptions;
 
-class OperatorLocalBroadcastRegister implements Observable.OnSubscribe<Intent> {
+class OnSubscribeLocalBroadcastRegister implements Observable.OnSubscribe<Intent> {
 
     private final Context context;
     private final IntentFilter intentFilter;
 
-    public OperatorLocalBroadcastRegister(Context context, IntentFilter intentFilter) {
+    public OnSubscribeLocalBroadcastRegister(Context context, IntentFilter intentFilter) {
         this.context = context;
         this.intentFilter = intentFilter;
     }

rxandroid/src/main/java/rx/android/content/OperatorSharedPreferenceChange.java renamed to rxandroid/src/main/java/rx/android/content/OnSubscribeSharedPreferenceChange.java

@@ -19,11 +19,11 @@
 import rx.functions.Action0;
 import rx.subscriptions.Subscriptions;
 
-class OperatorSharedPreferenceChange implements Observable.OnSubscribe<String>{
+class OnSubscribeSharedPreferenceChange implements Observable.OnSubscribe<String>{
 
     private final SharedPreferences sharedPreferences;
 
-    public OperatorSharedPreferenceChange(SharedPreferences sharedPreferences) {
+    public OnSubscribeSharedPreferenceChange(SharedPreferences sharedPreferences) {
         this.sharedPreferences = sharedPreferences;
     }
 

rxandroid/src/main/java/rx/android/view/OperatorViewClick.java renamed to rxandroid/src/main/java/rx/android/view/OnSubscribeViewClick.java

@@ -26,11 +26,11 @@
 import java.util.Map;
 import java.util.WeakHashMap;
 
-final class OperatorViewClick implements Observable.OnSubscribe<OnClickEvent> {
+final class OnSubscribeViewClick implements Observable.OnSubscribe<OnClickEvent> {
     private final boolean emitInitialValue;
     private final View view;
 
-    public OperatorViewClick(final View view, final boolean emitInitialValue) {
+    public OnSubscribeViewClick(final View view, final boolean emitInitialValue) {
         this.emitInitialValue = emitInitialValue;
         this.view = view;
     }

rxandroid/src/main/java/rx/android/view/ViewObservable.java

@@ -30,7 +30,7 @@ public static Observable<OnClickEvent> clicks(final View view) {
     }
 
     public static Observable<OnClickEvent> clicks(final View view, final boolean emitInitialValue) {
-        return Observable.create(new OperatorViewClick(view, emitInitialValue));
+        return Observable.create(new OnSubscribeViewClick(view, emitInitialValue));
     }
 
     /**

rxandroid/src/main/java/rx/android/widget/OperatorAdapterViewOnItemClick.java renamed to rxandroid/src/main/java/rx/android/widget/OnSubscribeAdapterViewOnItemClick.java

@@ -29,11 +29,11 @@
 import rx.android.AndroidSubscriptions;
 import rx.functions.Action0;
 
-class OperatorAdapterViewOnItemClick implements Observable.OnSubscribe<OnItemClickEvent> {
+class OnSubscribeAdapterViewOnItemClick implements Observable.OnSubscribe<OnItemClickEvent> {
 
     private final AdapterView<?> adapterView;
 
-    public OperatorAdapterViewOnItemClick(final AdapterView<?> adapterView) {
+    public OnSubscribeAdapterViewOnItemClick(final AdapterView<?> adapterView) {
         this.adapterView = adapterView;
     }
 

rxandroid/src/main/java/rx/android/widget/OperatorCompoundButtonInput.java renamed to rxandroid/src/main/java/rx/android/widget/OnSubscribeCompoundButtonInput.java

@@ -28,11 +28,11 @@
 import java.util.Map;
 import java.util.WeakHashMap;
 
-class OperatorCompoundButtonInput implements Observable.OnSubscribe<OnCheckedChangeEvent> {
+class OnSubscribeCompoundButtonInput implements Observable.OnSubscribe<OnCheckedChangeEvent> {
     private final boolean emitInitialValue;
     private final CompoundButton button;
 
-    public OperatorCompoundButtonInput(final CompoundButton button, final boolean emitInitialValue) {
+    public OnSubscribeCompoundButtonInput(final CompoundButton button, final boolean emitInitialValue) {
         this.emitInitialValue = emitInitialValue;
         this.button = button;
     }

rxandroid/src/main/java/rx/android/widget/OperatorTextViewInput.java renamed to rxandroid/src/main/java/rx/android/widget/OnSubscribeTextViewInput.java

@@ -23,11 +23,11 @@
 import android.text.TextWatcher;
 import android.widget.TextView;
 
-class OperatorTextViewInput implements Observable.OnSubscribe<OnTextChangeEvent> {
+class OnSubscribeTextViewInput implements Observable.OnSubscribe<OnTextChangeEvent> {
     private final boolean emitInitialValue;
     private final TextView input;
 
-    public OperatorTextViewInput(final TextView input, final boolean emitInitialValue) {
+    public OnSubscribeTextViewInput(final TextView input, final boolean emitInitialValue) {
         this.input = input;
         this.emitInitialValue = emitInitialValue;
     }

rxandroid/src/main/java/rx/android/widget/WidgetObservable.java

@@ -17,19 +17,19 @@ public static Observable<OnTextChangeEvent> text(final TextView input) {
     }
 
     public static Observable<OnTextChangeEvent> text(final TextView input, final boolean emitInitialValue) {
-        return Observable.create(new OperatorTextViewInput(input, emitInitialValue));
+        return Observable.create(new OnSubscribeTextViewInput(input, emitInitialValue));
     }
 
     public static Observable<OnCheckedChangeEvent> input(final CompoundButton button) {
         return input(button, false);
     }
 
     public static Observable<OnCheckedChangeEvent> input(final CompoundButton button, final boolean emitInitialValue) {
-        return Observable.create(new OperatorCompoundButtonInput(button, emitInitialValue));
+        return Observable.create(new OnSubscribeCompoundButtonInput(button, emitInitialValue));
     }
 
     public static Observable<OnItemClickEvent> itemClicks(final AdapterView<?> adapterView) {
-        return Observable.create(new OperatorAdapterViewOnItemClick(adapterView));
+        return Observable.create(new OnSubscribeAdapterViewOnItemClick(adapterView));
     }
 
     /**