import java.lang.ref.WeakReference;
+import rx.Observable;
+import rx.schedulers.Schedulers;
+
import static com.enqualcomm.support.Constants.ACTION_ANTI_OFF;
import static com.enqualcomm.support.Constants.ACTION_ANTI_OFF0;
import static com.enqualcomm.support.Constants.ACTION_CHECK_ANTIOFF_EVENT;
* 启动传感器。
*/
private void startSensor() {
- mSensorManager = (SensorManager) mContext.getSystemService(Context.SENSOR_SERVICE);
- Sensor mSensor = mSensorManager.getDefaultSensor(Sensor.TYPE_PROXIMITY);
-
- if (mSensorManager == null || mSensor == null) {
- ICLogger.i("Proximity 设备不支持1");
- return;
- //throw new UnsupportedOperationException("设备不支持");
- }
+ Observable.create(subscriber -> {
+ mSensorManager = (SensorManager) mContext.getSystemService(Context.SENSOR_SERVICE);
+ if (mSensorManager == null) {
+ ICLogger.i("Proximity 设备不支持1");
+ return;
+ //throw new UnsupportedOperationException("设备不支持");
+ }
+ Sensor mSensor = mSensorManager.getDefaultSensor(Sensor.TYPE_PROXIMITY);
+ if (mSensor == null) {
+ ICLogger.i("Proximity 设备不支持1 as no sensor..");
+ }
- boolean isRegister = mSensorManager.registerListener(mSensorEventListener, mSensor, SensorManager.SENSOR_DELAY_NORMAL);
- if (!isRegister) {
- ICLogger.i("Proximity 设备不支持2");
- //throw new UnsupportedOperationException("设备不支持");
- return;
- }
+ boolean isRegister = mSensorManager.registerListener(mSensorEventListener, mSensor, SensorManager.SENSOR_DELAY_NORMAL);
+ if (!isRegister) {
+ ICLogger.i("Proximity 设备不支持2");
+ //throw new UnsupportedOperationException("设备不支持");
+ }
+ }).subscribeOn(Schedulers.io()).subscribe();
}