fromAsync-3.java

Observable<SensorEvent> naiveObserveSensorChanged(final SensorManager sensorManager, final Sensor sensor, final int samplingPreiodUs) { 
  return Observable.create(new Observable.OnSubscribe<SensorEvent>() { 
    @Override 
    public void call(final Subscriber<? super SensorEvent> subscriber) { 
      SensorEventListener sensorEventListener = new SensorEventListener() { 
        @Override 
        public void onSensorChanged(SensorEvent event) { 
          subscriber.onNext(event); 
        } 

        @Override 
        public void onAccuracyChanged(Sensor sensor, int accuracy) { 
          // ignored for this example 
        } 
      }; 
      sensorManager.registerListener(sensorEventListener, sensor, samplingPreiodUs); 
    } 
  }); 
}