Я занимаюсь разработкой простого погодного приложения и пытаюсь получить данные с помощью модернизации.Я отлаживаю код.
compositedisposable.add (apiservi by ..... Здесь, в 36-й строке при отладке «переменные недоступны», записывает и останавливает, я не могу вытащить данные.
-> newConsumer ... показывает следующее предложение.
"Информация проверки анонимного нового потребителя (Ctrl + F1): сообщает о всех анонимных классах Лямбда-синтаксис не поддерживается в Java 1.7 или более ранних версиях JVM."
Если вы хотите просмотреть GithubLink: https://github.com/rumtblbl/LocationWeatherApp
Пожалуйста, помогите мне, спасибо. WeatherCityNameServiceImp.java
package com.example.locationweatherapp.Data.Network.Service;
import android.view.View;
import android.widget.Toast;
import com.example.locationweatherapp.Data.Network.ApiClient;
import com.example.locationweatherapp.Data.Network.ApiInterface;
import com.example.locationweatherapp.Data.Network.Model.WeatherResult;
import com.example.locationweatherapp.Utility.Utils;
import com.squareup.picasso.Picasso;
import javax.inject.Inject;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.functions.Consumer;
import io.reactivex.schedulers.Schedulers;
public class WeatherCityNameServiceImp implements WeatherCityNameService {
private ApiInterface apiService;
CompositeDisposable compositeDisposable;
@Inject
public WeatherCityNameServiceImp() {
apiService = ApiClient.getClient().create(ApiInterface.class);
compositeDisposable = new CompositeDisposable();
}
@Override
public void weatherCityNameService(String cityName, final ServiceCallBack<WeatherResult> callBack) {
compositeDisposable.add(apiService.weatherCityNameService(cityName, Utils.APP_ID, "metric")
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<WeatherResult>() {
@Override
public void accept(WeatherResult weatherResult) throws Exception {
callBack.onResponse(weatherResult);
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
callBack.onError(throwable.getMessage());
}
})
);
}
}