如何解析 RxJava 以接收我想要的数据？

Question

我只想要数字，但这是我在日志中收到的：

[牛肝菌（等级=4.5），牛肝菌（等级=9.5）]

回应：

public class GradeResponse {

    @Inject
    Retrofit retrofit;

    @Inject
    MainPresenter mainPresenter;

    public void getGradeRx() {

        MyApplication.getMainComponent().injectIntoGradeResponse(this);// informando ao dagger sobre o uso de um component e a necessidade de injetar dependência

        Subscription getGrade = retrofit
                .create(GradeService.class)
                .getGrade()
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .map(model -> {

                    return model.getBoletim();

                })
                .subscribe(new Observer<Boletim[]>() {
                    @Override
                    public void onCompleted() {

                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.i(TAG, "saporra vai me matar ainda");
                    }

                    @Override
                    public void onNext(Boletim[] grades) {
                        Log.i(TAG, Arrays.asList(grades).toString());
                    }
                });
    }
}

模型：

GradeModel：

@SerializedName("boletim")
    @Expose
    private Boletim[] boletim;

Boletim.class

public class Boletim {

    @SerializedName("grade")
    @Expose
    private double grade;

改造服务正常，依赖注入工作。我从 rxJava 接收 onSuccess 方法，我现在只需要接收没有这个 "[Boletim(grade=".

的数字

Answer 1

您看到对象的 toString 是因为您在地图中获得了整个对象！

只有没有这个“[Boletim(grade=".

您不能再次映射并提取它吗？

.map(model -> {               // This map returns a Boletim[]
     return model.getBoletim();
 })
.map(boletim -> {             // This map returns a double[]
    Double grades = new Double[boletim.length];
    for (int i =0; i < grades.length ; i++) {
        grades[i] = boletim[i].getGrade() ;
    } 
    return grades;
}).subscribe(new Observer<Double[]>() {   // This subscribes to a double[]
    @Override
    public void onCompleted() {

    }

    @Override
    public void onError(Throwable e) {
        Log.i(TAG, "saporra vai me matar ainda");
    }

    @Override
    public void onNext(Double[] grades) {
        Log.i(TAG, Arrays.toString(grades));
    }
}

或者你可以将 for 循环放入 onNext

如果你不想要一个 Observable 数组，那么使用 flatMap