Android开发 RxPermissions使用以及自定义相机拍照demo

/** * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * <p> * http://www.apache.org/licenses/LICENSE-2.0 * <p> * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.tbruyelle.rxpermissions3; import android.Manifest; import android.annotation.TargetApi; import android.app.Activity; import android.content.pm.PackageManager; import android.os.Build; import androidx.fragment.app.FragmentActivity; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.mockito.ArgumentCaptor; import org.mockito.ArgumentMatchers; import org.robolectric.Robolectric; import org.robolectric.RobolectricTestRunner; import org.robolectric.android.controller.ActivityController; import org.robolectric.annotation.Config; import io.reactivex.rxjava3.core.Observable; import io.reactivex.rxjava3.observers.TestObserver; import io.reactivex.rxjava3.subjects.PublishSubject; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; import static org.mockito.Matchers.anyString; import static org.mockito.Matchers.eq; import static org.mockito.Mockito.doCallRealMethod; import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.spy; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; @RunWith(RobolectricTestRunner.class) @Config(sdk = Build.VERSION_CODES.M) public class RxPermissionsTest { private FragmentActivity mActivity; private RxPermissions mRxPermissions; @Before public void setup() { ActivityController<FragmentActivity> activityController = Robolectric.buildActivity(FragmentActivity.class); mActivity = spy(activityController.setup().get()); mRxPermissions = spy(new RxPermissions(mActivity)); mRxPermissions.mRxPermissionsFragment = spy(mRxPermissions.mRxPermissionsFragment); final RxPermissionsFragment rxPermissionsFragment = spy(mRxPermissions.mRxPermissionsFragment.get()); when(rxPermissionsFragment.getActivity()).thenReturn(mActivity); when(mRxPermissions.mRxPermissionsFragment.get()).thenReturn(rxPermissionsFragment); // Default deny all permissions doReturn(false).when(mRxPermissions).isGranted(anyString()); // Default no revoked permissions doReturn(false).when(mRxPermissions).isRevoked(anyString()); } private Observable<Object> trigger() { return Observable.just(RxPermissions.TRIGGER); } @Test @TargetApi(Build.VERSION_CODES.M) public void subscription_preM() { TestObserver<Boolean> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(true); trigger().compose(mRxPermissions.ensure(permission)).subscribe(sub); sub.assertNoErrors(); sub.assertValue(true); } @Test @TargetApi(Build.VERSION_CODES.M) public void subscription_granted() { TestObserver<Boolean> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(false); int[] result = new int[]{PackageManager.PERMISSION_GRANTED}; trigger().compose(mRxPermissions.ensure(permission)).subscribe(sub); mRxPermissions.onRequestPermissionsResult(new String[]{permission}, result); sub.assertNoErrors(); sub.assertValue(true); } @Test @TargetApi(Build.VERSION_CODES.M) public void eachSubscription_granted() { TestObserver<Permission> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(false); int[] result = new int[]{PackageManager.PERMISSION_GRANTED}; trigger().compose(mRxPermissions.ensureEach(permission)).subscribe(sub); mRxPermissions.onRequestPermissionsResult(new String[]{permission}, result); sub.assertNoErrors(); sub.assertValue(new Permission(permission, true)); } @Test @TargetApi(Build.VERSION_CODES.M) public void eachSubscriptionCombined_granted() { TestObserver<Permission> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(false); int[] result = new int[]{PackageManager.PERMISSION_GRANTED}; trigger().compose(mRxPermissions.ensureEachCombined(permission)).subscribe(sub); mRxPermissions.onRequestPermissionsResult(new String[]{permission}, result); sub.assertNoErrors(); sub.assertValue(new Permission(permission, true)); } @Test @TargetApi(Build.VERSION_CODES.M) public void eachSubscription_preM() { TestObserver<Permission> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(true); trigger().compose(mRxPermissions.ensureEach(permission)).subscribe(sub); sub.assertNoErrors(); sub.assertValue(new Permission(permission, true)); } @Test @TargetApi(Build.VERSION_CODES.M) public void eachSubscriptionCombined_preM() { TestObserver<Permission> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(true); trigger().compose(mRxPermissions.ensureEachCombined(permission)).subscribe(sub); sub.assertNoErrors(); sub.assertValue(new Permission(permission, true)); } @Test @TargetApi(Build.VERSION_CODES.M) public void subscription_alreadyGranted() { TestObserver<Boolean> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(true); trigger().compose(mRxPermissions.ensure(permission)).subscribe(sub); sub.assertNoErrors(); sub.assertValue(true); } @Test @TargetApi(Build.VERSION_CODES.M) public void subscription_denied() { TestObserver<Boolean> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(false); int[] result = new int[]{PackageManager.PERMISSION_DENIED}; trigger().compose(mRxPermissions.ensure(permission)).subscribe(sub); mRxPermissions.onRequestPermissionsResult(new String[]{permission}, result); sub.assertNoErrors(); sub.assertValue(false); } @Test @TargetApi(Build.VERSION_CODES.M) public void eachSubscription_denied() { TestObserver<Permission> sub = new TestObserver<>(); String permission = Manifest.permission.READ_PHONE_STATE; when(mRxPermissions.isGranted(permission)).thenReturn(false); int[] result = new int[]{PackageManager.PERMISSION_DENIED}; trigger().compose(mRxPermissions.ensureEach(permission)).subscribe(sub); mRxPermissions.onRequestPermissionsResult(new String[]{permission}, result); sub.assertNoErrors(); sub.assertValue(new Permission(permission, false)); } @Test @TargetApi(Build.VERSION_CODES.M) public void eachSubscriptionCombined_denied() { TestObserver<Permission> sub = new TestObserver<>(); String permission = Manif