0

Метод takePicture(...) из android.hardware.Camera имеет тип возвращаемого значения void

public final void takePicture(ShutterCallback shutter, PictureCallback raw, PictureCallback jpeg) {
   takePicture(shutter, raw, null, jpeg);
}

Как реализовать возврат Observable<Bitmap> из Camera.PictureCallback? Использую RxJava2.

public Observable<Bitmap> getBitmap() {
   camera.takePicture(null, null, new Camera.PictureCallback() {
      @Override
      public void onPictureTaken(byte[] data, Camera camera) {
         return data; // <<< ???
      }
   });
}

P.S. Я не стал писать код, где перевожу data в bitmap, думаю это к делу не относится. Можно пример с любым возвращаемым типом.

2 ответа 2

1
public Observable<Bitmap> getBitmap() {
   ReplaySubject<Bitmap> subject = ReplaySubject.create();
   camera.takePicture(null, null, new Camera.PictureCallback() {
      @Override
      public void onPictureTaken(byte[] data, Camera camera) {
         Bitmap bitmap = BitmapFactory.decodeByteArray(data , 0, data.length);
         subject.onNext(bitmap);
      }
   });
   return subject;
}
2
  • Сергей, спасибо за ответ. Я первый раз вижу ReplaySubject, можете объяснить или дать ссылку где я могу понять разницу между ReplaySubject.create() и Observable.create()? Если это имеет какое то значение, я использую io.reactivex.rxjava2:rxjava:2.1.16. 11 окт 2018 в 18:21
  • ReplaySubject - это наследник Observable, позволяющий публиковать события. Почитать можно тут например. 11 окт 2018 в 18:27
0

Нашел пример, переписал под свои нужны, все работает, получаю bitmap. Но я практически не понимаю внутреннего устройства RxJava2 (пока еще сложно для меня). Я точно не вспомню, но не раз читал, что с RxJava нужно быть аккуратным, т.к. можно получить какие то ошибки или что то может пойти не так (что именно не вспомню). Верно ли то, что я написал. Могут ли быть какие то грабли?

public Observable<Bitmap> takePicture() {
   return Observable.create(emitter -> {
      try {
         camera.takePicture(null, null, (data, camera) -> {
            emitter.onNext(convert(data));
            emitter.onComplete(); // №1 необходимо ли это?
         });
      } catch (Exception e) {
         emitter.onError(e);
      }
   });
}
4
  • Так даже лучше, пожалуй. Вызов onComplete сигнализирует о том, что больше ничего отправляться не будет. Его стоит использовать. 11 окт 2018 в 18:37
  • @SergeyGornostaev просто когда я пишу код, я стараюсь понимать полностью как это работает, т.к. от недопонимания можно долго не понимать, почему же все идет не так, как ты хочешь :)... и я не понимаю, какое в данном случае я получу поведение с emitter.onComplete(); и без него. 11 окт 2018 в 18:42
  • Если ваш код на возвращаемый Observable не вешает обработчик onComplete, то разницы вы можете и не заметить. 11 окт 2018 в 18:53
  • @SergeyGornostaev хм... т.е. onComplete нужен только тогда, когда мне необходимо конкретно это событие... например цикл for испускает 0...9 я их получаю и обрабатываю, но не узнаю что цифр больше не будет, с onComplete я знаю, что цифр больше не будет и могу реализовать какую то логику, основанную на этом? 11 окт 2018 в 19:04

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.