2

Добрый день есть функция rxJava и есть метод flatMap:

@Override
public Observable<AuthorizationEntity> confirmVerificationCode(String email,int verificationCode) {
    return restClient.getVerificationApi(email,verificationCode)
            .flatMap((Function<Response<ResponseBody>, Observable<AuthorizationEntity>>) responseBodyResponse -> {
                Gson gson = new Gson();
                AuthorizationEntity authorizationEntity = gson.fromJson(responseBodyResponse.body().string(), AuthorizationEntity.class);
                authorizationEntity.setToken(responseBodyResponse.headers().get("MPOS_AUTH_TOKEN"));
                return Observable.fromArray(authorizationEntity);
            })
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread());
}

как из этого flatMap вынесни ламбда в отдельный метод и использовать конструкцию вида this::method?

2
  • 1
    Хоть убей не понимаю, что не так в вопросе и за что минусуют
    – chubatiy
    29 мая 2018 в 13:09
  • @Chubatiy ))) дети играются наверно)
    – elik
    29 мая 2018 в 13:10

1 ответ 1

4

Все очень просто:

  1. выносите лямбду в отдельный метод с соотвествующей сигнатурой

    private static Observable<AuthorizationEntity> parse(Response<ResponseBody> responseBodyResponse)
    
  2. в местах, где использовалась лямбда, пишите следующее:

    .flatMap(MySuperClass::parse)
    

ps если в сигнатуре убрать static, то обращение к методу будет происходить через this, и вызов соответственно будет выглядеть так:

.flatMap(this::parse)

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.