remove main thread unsubscribe, fix LocalBroadcastOperatorTest

Author: Yarikx

rxjava-contrib/rxjava-android/src/main/java/rx/operators/OperatorBroadcastRegister.java

@@ -24,8 +24,8 @@
 import rx.Observable;
 import rx.Subscriber;
 import rx.Subscription;
-import rx.android.subscriptions.AndroidSubscriptions;
 import rx.functions.Action0;
+import rx.subscriptions.Subscriptions;
 
 public class OperatorBroadcastRegister implements Observable.OnSubscribe<Intent> {
 
@@ -50,7 +50,7 @@ public void onReceive(Context context, Intent intent) {
             }
         };
 
-        final Subscription subscription = AndroidSubscriptions.unsubscribeInUiThread(new Action0() {
+        final Subscription subscription = Subscriptions.create(new Action0() {
             @Override
             public void call() {
                 context.unregisterReceiver(broadcastReceiver);

rxjava-contrib/rxjava-android/src/main/java/rx/operators/OperatorLocalBroadcastRegister.java

@@ -26,6 +26,7 @@
 import rx.Subscription;
 import rx.android.subscriptions.AndroidSubscriptions;
 import rx.functions.Action0;
+import rx.subscriptions.Subscriptions;
 
 public class OperatorLocalBroadcastRegister implements Observable.OnSubscribe<Intent> {
 
@@ -47,7 +48,7 @@ public void onReceive(Context context, Intent intent) {
             }
         };
 
-        final Subscription subscription = AndroidSubscriptions.unsubscribeInUiThread(new Action0() {
+        final Subscription subscription = Subscriptions.create(new Action0() {
             @Override
             public void call() {
                 localBroadcastManager.unregisterReceiver(broadcastReceiver);

rxjava-contrib/rxjava-android/src/test/java/rx/android/operators/OperatorLocalBroadcastRegisterTest.java

@@ -42,7 +42,6 @@
 public class OperatorLocalBroadcastRegisterTest {
 
     @Test
-    @SuppressWarnings("unchecked")
     public void testLocalBroadcast() {
         String action = "TEST_ACTION";
         IntentFilter intentFilter = new IntentFilter(action);
@@ -64,6 +63,7 @@ public void testLocalBroadcast() {
         inOrder.verify(observer, times(1)).onNext(intent);
 
         subscription.unsubscribe();
+        localBroadcastManager.sendBroadcast(intent);
         inOrder.verify(observer, never()).onNext(any(Intent.class));
 
         inOrder.verify(observer, never()).onError(any(Throwable.class));