java - React Native 与 RxJava 通信

Question

我正在用 React Native 为移动支付终端构建一个应用程序。我正在使用PagSeguro SDK女巫是用 Java 构建的，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);