SecondPageController.java 文件源码

private void initPendingTransactionsButton() {
    pendingTransactions.setOnAction(event -> {
        clearTable();
        result.setText("");

        // ==> Here is how the api in store requests are invoked. The Rx Observable pattern is used.
        // here a re some reference:
        //  - http://reactivex.io
        //  - https://github.com/ReactiveX/RxJava
        persistenceProtoCore
                .getTransactionHistory(20, null, "proposed")
                .subscribeOn(Schedulers.newThread())
                .take(1)
                .subscribe(historyTransactionsModel ->
                        Platform.runLater(() -> {
                                    acceptButton.setDisable(false);
                                    refuseButton.setDisable(false);
                                    refundButton.setDisable(true);

                                    transactionsTable.setItems(
                                            FXCollections.observableList(historyTransactionsModel.getList())
                                    );
                                    transactionsTable.refresh();
                                }
                        )
                );
    });
}