Форум программистов, компьютерный форум CyberForum.ru
Наши страницы

Программирование Android

Войти
Регистрация
Восстановить пароль
 
yura91
1 / 25 / 2
Регистрация: 23.10.2013
Сообщений: 2,301
#1

Rx Java - Программирование Android

18.07.2016, 21:55. Просмотров 263. Ответов 2
Метки нет (Все метки)

Если запустить запрос на сервер в Observable в приложении где основной поток Ui. то эта сетевая операция создастся в новом потоке или будет выполнятся в том же что и ui? Можете объяснить?

Добавлено через 1 минуту
В Observable нужно создавать новый поток для сетевых операции или необязательно Observable и так запустит ее в новом потоке?
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
18.07.2016, 21:55
Здравствуйте! Я подобрал для вас темы с ответами на вопрос Rx Java (Программирование Android):

Ошибка java.lang.ClassCastException: com.organizer.ToDoItemDescr cannot be cast to java.util.Map - Программирование Android
Ошибка появляется когда пытаюсь вытянуть из кастомного адаптера запись ListView. Весь лог ошибки такой: FATAL EXCEPTION: main Process:...

Не создаются BuildConfig.java R.java - Программирование Android
BuildConfig.java , R.java Не создаются в папке /gen при создании проекта в eclipse. Переустанавливал программу, ничего не помогает. Что...

Какую версию Java поддерживает .Net Java# И какую VS6.0 Java++ ? - Java
Какую версию Java поддерживает .Net Java# И какую VS6.0 Java++ ? Ответье, плиз, новичку, по MSDN я не понятно, это исключительно...

Ошибка reference to List is ambiguous; both interface java.util.List in package java.util and class java.awt.List in... - Java
Почему кгда я загружаю пакеты awt, utill вместе в одной проге при обьявлении елемента List я ловлю такую ошибку. 'listTest.java':...

Посоветуйте примеры кода по Java. Теория прочтена, но с языком Java не знакома - Java
Или может кто может дать готовый код. В теории вроде бы не очень сложно. :cry: 1.Напишите процедуру, которая по заданному сообщению...

Что оптимальнее для почтового сервиса - java.IO или java.NIO? - Java Сети
Пишу серверную часть мобильного приложения под Android на JDK, в которое будет интегрирован почтовый сервис, подгрузка новостей, личный...

2
xoraxax
821 / 775 / 186
Регистрация: 05.07.2013
Сообщений: 3,576
Завершенные тесты: 1
19.07.2016, 11:12 #2
как вообще одно с другим связано?
0
yura91
1 / 25 / 2
Регистрация: 23.10.2013
Сообщений: 2,301
19.07.2016, 19:41  [ТС] #3
Просто у меня есть код под андроид
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
 @Override
    public void onActivityCreated(@Nullable Bundle savedInstanceState) {
        super.onActivityCreated(savedInstanceState);
 
        String dummyAppid = "4e8c04b23fb7e5b3a3e34d8d8dd16537";
        final String OPEN_WEATHER_MAP_API_FORCAST = "http://api.openweathermap.org/data/2.5/forecast?q=";
        final String PlaceApi = "https://maps.googleapis.com/maps/api/place/nearbysearch/json?location=";
        String PlaceKey = "AIzaSyAwx56WATgijTEJAIoHmaCRc1935KB4vGs";
        final String placeApiKey = "&key=" + PlaceKey;
        final String queryDummyKey = "&appid=" + dummyAppid;
        List<Address> addresses = null;
        double lat = MainActivity.latitude;
        double lon = MainActivity.longitude;
 
 
 
        String queryForecast = null;
        try {
            addresses = geocoder.getFromLocation(lat, lon, 1);
            String cityName = null;
            if (addresses != null && addresses.size() > 0) {
                String addressLine = addresses.get(0).getAddressLine(0);
                cityName = addresses.get(0).getLocality();
                Log.d("Func", "cityName " + cityName + "adresses" + addresses.size() + addressLine + lat + lon);
                queryForecast = OPEN_WEATHER_MAP_API_FORCAST + URLEncoder.encode(cityName, "UTF-8") + queryDummyKey;
            }
        }catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        subscription = getGistObservable(queryForecast)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<Response>() {
                    @Override
                    public void onCompleted() {
 
                    }
 
                    @Override
                    public void onError(Throwable e) {
                        Log.e("Func", e.getMessage(), e);
                    }
 
                    @Override
                    public void onNext(Response gist) {
 
                        try {
                            Log.e("Func", "Response       " + gist.toString());
                            Log.e("Func", "Response       " + gist.body().string());
 
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
 
                    }
                });
 
    }
 
 
    @Nullable
    private Response getGist(String url) throws IOException {
 
        OkHttpClient client = new OkHttpClient();
 
        Request request = new Request.Builder()
                .url(url)
                .build();
 
        Response response = client.newCall(request).execute();
 
        if (response.isSuccessful()) {
 
            return response;
        }
 
        return null;
 
    }
 
    public Observable<Response> getGistObservable(String url) {
        return Observable.defer(new Func0<Observable<Response>>() {
            @Override
            public Observable<Response> call() {
                try {
 
                    return Observable.just(getGist(url));
                } catch (IOException e) {
                    return Observable.error(e);
                }
            }
        });
    }
 
    @Override
    public void onDestroy() {
        super.onDestroy();
        if(subscription != null && !subscription.isUnsubscribed()) {
            subscription.unsubscribe();
        }
    }
Здесь делается, через библиотеку OkHttp, один запрос, мне приходит ответ в Response. А я хочу переделать этот код на случай если я делаю 2 запроса и в onNext получать 2 Response и обрабатывать их. Как грамотно переделать этот код чтобы он был максимально компактным для двух запросов?

Добавлено через 2 минуты
Просто делать для каждого запроса если их 2
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
subscription = getGistObservable(queryForecast)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<Response>() {
                    @Override
                    public void onCompleted() {
 
                    }
 
                    @Override
                    public void onError(Throwable e) {
                        Log.e("Func", e.getMessage(), e);
                    }
 
                    @Override
                    public void onNext(Response gist) {
 
                        try {
                            Log.e("Func", "Response       " + gist.toString());
                            Log.e("Func", "Response       " + gist.body().string());
 
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
 
                    }
                });
Не очень удобно. Код будет дублироваться и для первого запроса этот код и для второго. Как учесть 2 Http запроса в одном этом фрагменте кода?
0
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
19.07.2016, 19:41
Привет! Вот еще темы с ответами:

При работе JVM обвалвается java c кодом Java Result 1073807364. - Java
При работе JVM обвалвается java c кодом Java Result 1073807364. Если кто-нибудь знает, помогите пожалуйста.

Java.lang.IllegalArgumentException в нативных функциях (embedded Java, MicroEJ, STM32F4Discovery) - Микроконтроллеры
Добрый день! Пытаюсь связать embedded Java и C посредством нативных функций. Идея в следующем: мне нужно вернуть из нативной...

Java сервер Flash клиент java.io.StreamCorruptedException: invalid stream header - Java EE
Есть класс сериализованный на стороне java (сервер) и actionscript(клиент). При попытке передачи объекта от клиента к серверу вылетает...

Эволюция Java разработчика, или как начать писать на JAVA EE? - Java EE
Всем добрые сутки и чая с печеньем. Предлагаю сразу к делу. Я примерно пол года читал книги по Java, до этого писал пару сайтов на...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
3
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru