android - 将无限次调用的回调转换为 Observable

Question

假设我有一个将被调用无限次的回调

公共(public)接口(interface)回调{
void onPreview(byte[] 数据);
}

但我需要在 camera.setPreviewCallback(Callback cb);

中提前设置它

如何使用 RxJava 正确处理这种情况？我想从这个流中异步获取数据，尤其是当我完成工作时。

Answer 1

您可以使用 Observable.fromEmitter 并从 Observable.fromEmitter 的主体设置 camera.setPreviewCallback(Callback cb)

 public void stuff() {
       Observable<Byte[]> obs = Observable.fromEmitter(emitter -> {
              Callback cb = bytes -> emitter.onNext(bytes);
              camera.setPreviewCallback(cb);
       }

       obs.subscribe(bytes -> /* perform with bytes */);

 }

(使用 java 8 语法只是为了清晰起见/即:您可以构建匿名类而不是 lambda)