java - React Native は RxJava と通信します

Question

React Native でモバイル決済端末用のアプリケーションを構築しています。Java でビルドされたPagSeguro SDKを使用しています。Java と React 間の接続は Native Modules で行われます。

私はすべての支払いプロセスを完了しましたが、プロセスのどのステップにいるのかをユーザーに伝える必要があり、そのために RxJava ObservableEmitter イベントをキャッチする必要がありますが、それを行う方法を見つけることができません。道順を教えてください。

Javaコードは次のとおりです。

@ReactMethod
public Observable<ActionResult> doPayment(ReadableMap data) {
  PlugPagPaymentData paymentData = new PlugPagPaymentData(
    data.getInt("tipo"),
    data.getInt("valor"),
    data.getInt("pagamento"),
    data.getInt("parcelas"),
    data.getString("codvenda")
  ));

  return Observable.create(emitter -> {
    plugPag.setPlugPagCustomPrinterLayout(getCustomPrinterDialog());
    ActionResult result = new ActionResult();
    setListener(emitter, result);
    setPrinterListener(emitter, result);
    PlugPagTransactionResult plugPagTransactionResult = plugPag.doPayment(paymentData);
    sendResponse(emitter, plugPagTransactionResult, result);
  });
}

JS では、支払い方法を呼び出すだけです。

infos = {
  tipo: metodo_pagamento,
  valor: valor_centavos,
  pagamento: 1,
  parcelas: parcelas,
  codvenda: pedido_id
}
const payment = await Apos.doPayment(infos);