Какаято смесь JavaScript + Pascal

Ты это Одерски скажи в лицо про Scala

ребят можете помочь с вопросом? хочу сделать 2 хттп запроса из презентера, вот только во втором запросе в урл должна быть дата из первого запроса. хочу понять как через ретрофит собрать респонсы с двух этих запросов, и обьединить в один класс, чтобы уже передать моему вю чтобы тот показал. проблема в том что ответы на запросы идут и получаются асинхронно, и не знаю как обьединить

запросы такие, первый идет BASE_URL + "/channels"

второй BSAE_URL + "/epg/{listOfIds}"

первый должен вернуть ChannelList в котором есть List<Channel>

второй EpgList в котором есть List<Epg>

Что такое Kotlin??

уроки по Kotlin https://youtu.be/L9k_NdTaMeI

ребят можете помочь с вопросом? хочу сделать 2 хттп запроса из презентера, вот только во втором запросе в урл должна быть дата из первого запроса. хочу понять как через ретрофит собрать респонсы с двух этих запросов, и обьединить в один класс, чтобы уже передать моему вю чтобы тот показал. проблема в том что ответы на запросы идут и получаются асинхронно, и не знаю как обьединить

На колбеке первого запроса выполнять второй?

На колбеке первого запроса выполнять второй?

ага, и потом все это вместе вернуть тому кто вызывал

ребят можете помочь с вопросом? хочу сделать 2 хттп запроса из презентера, вот только во втором запросе в урл должна быть дата из первого запроса. хочу понять как через ретрофит собрать респонсы с двух этих запросов, и обьединить в один класс, чтобы уже передать моему вю чтобы тот показал. проблема в том что ответы на запросы идут и получаются асинхронно, и не знаю как обьединить

класно использовать rx

класно использовать rx

kak?

класно использовать rx

вот стоит у меня такой АПИ

класно использовать rx

public interface TvApi { @GET("/channels") Call<ChannelList> getChannelList(); @GET("/epg/currentProgram/{channelList}/") Call<EpgList> getCurrentEpgList(@Path("channelList") List<String> channelList); }

https://habrahabr.ru/company/rambler-co/blog/275943/

здесь достаточно детально описано как и что

сам сейчас проходжу

плюс примеры на github сразу есть, по веткам разделено

Давай уточним: первый запрос вернет ченелы, а что потом? Из етих ченелов достать айдишки и передать их во второй запрос?

Давай уточним: первый запрос вернет ченелы, а что потом? Из етих ченелов достать айдишки и передать их во второй запрос?

именно

https://habrahabr.ru/company/rambler-co/blog/275943/

сейчас прочту, спасибо

И Rx к проекту подключен?

И Rx к проекту подключен?

да, фаст андроид

привильно я понимию, к примеру вот здесь нужно второй зарос описать ?

Тогда с ретрофита нужно возвращать синглы @GET("/channels") Single<ChannelList> getChannelList(); @GET("/epg/currentProgram/{channelList}/") Single<EpgList> getCurrentEpgList(@Path("channelList") List<String> channelList);

aga

Тогда с ретрофита нужно возвращать синглы @GET("/channels") Single<ChannelList> getChannelList(); @GET("/epg/currentProgram/{channelList}/") Single<EpgList> getCurrentEpgList(@Path("channelList") List<String> channelList);

можете дать понятную ссылку, как работают синглы, и вообще ретрофит? я ни с ретрофитом, ни с фаст нетворкингом так и не разобрался до конца

Тогда с ретрофита нужно возвращать синглы @GET("/channels") Single<ChannelList> getChannelList(); @GET("/epg/currentProgram/{channelList}/") Single<EpgList> getCurrentEpgList(@Path("channelList") List<String> channelList);

у меня так грузится в презентере сейчас

Тогда с ретрофита нужно возвращать синглы @GET("/channels") Single<ChannelList> getChannelList(); @GET("/epg/currentProgram/{channelList}/") Single<EpgList> getCurrentEpgList(@Path("channelList") List<String> channelList);

private void loadData() { Observable<ChannelList> channels = NetworkService.getChannels(); mChannelsSubscription = channels.subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber<ChannelList> () ) { @Override public void onCompleted() { view().showChannelList(mChannelList); } @Override public void onError(Throwable e) { view().showError("unable to load channels"); // TODO: 3/25/2017 replace with normal message } @Override public void onNext(ChannelList channelList) { mChannelList = channelList.getChannelInfoList(); } }); }

Тогда с ретрофита нужно возвращать синглы @GET("/channels") Single<ChannelList> getChannelList(); @GET("/epg/currentProgram/{channelList}/") Single<EpgList> getCurrentEpgList(@Path("channelList") List<String> channelList);

вот как тут вставить EPG?

И будет ка-то так: retrofit.getChannelList().flatMap(chanels -> { List<String> ids = получаешь как тебе нужно return retrofit.getCurrentEpgList(ids) })

И будет ка-то так: retrofit.getChannelList().flatMap(chanels -> { List<String> ids = получаешь как тебе нужно return retrofit.getCurrentEpgList(ids) })

тут согласен, но мне и ответ на первый запрос то нужно сохранить заодно

кажется есть реализация flatMap, которая позволяет не потерять и предыдущия данные.

И будет ка-то так: retrofit.getChannelList().flatMap(chanels -> { List<String> ids = получаешь как тебе нужно return retrofit.getCurrentEpgList(ids) })

Аха, кто то пишет IPTV

Аха, кто то пишет IPTV

ну да)

Плеер какой используете?

Плеер какой используете?

пока не дошел до плеера)) но думаю этот возьмем

Плеер какой используете?

https://github.com/afollestad/easy-video-player

А почему не просто MediaPlayer?

с ним проблем много, с перехода от live к catchup

Observable<ChannelList> channels = NetworkService.getChannels(); Observable<ChannelProgram> channelProgramList = channels.flatMap(channelList -> { List<String> channelIdList = new ArrayList<> ()); for (ChannelInfo chInfo : channelList.getChannelInfoList()){ channelIdList.add(chInfo.getId()); } Observable<EpgList> epgList = NetworkService.getCurrentEpgList(channelIdList); return ?????; });

вот мне примерно это нужно, но как тут обьединить эти два обзервабала, не знаю

что-то такое не подойдет? http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Observable.html#flatMap(io.reactivex.functions.Function,%20io.reactivex.functions.BiFunction)

ой) ну это функниональное програмирование с rx )

капец какойто ))

во flatmap следущий observable

ой) ну это функниональное програмирование с rx )

удобно же :)

удобно же :)

когда ты в этом уже гик )

Так во всем так: пока не разберешься - хрен что нормально получится

Так во всем так: пока не разберешься - хрен что нормально получится

ну да, просто он необычный, для начала, очень даже )

что ребят, надежды нет?

Я же скидывал. Или не подошло? Там вторым параметром передается комбинирующая функция

что-то такое не подойдет? http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Observable.html#flatMap(io.reactivex.functions.Function,%20io.reactivex.functions.BiFunction)

что-то такое не подойдет? http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Observable.html#flatMap(io.reactivex.functions.Function,%20io.reactivex.functions.BiFunction)

если честно ни хрена не понял в картинке и флатмап)

https://github.com/afollestad/easy-video-player

Просто интересна обертка для MediaPlayer для удобства конфигурации. Тока учти что внутри используется TextureView, которая может иметь проблемы с производительностью. В инете куча топиков SurfaceView vs TextureView.

если честно ни хрена не понял в картинке и флатмап)

retrofit.getChannelList().flatMap(chanels -> { List<String> ids = получаешь как тебе нужно return retrofit.getCurrentEpgList(ids) }, (chanels, epgList) -> { комбинируешь как тебе надо })

retrofit.getChannelList().flatMap(chanels -> { List<String> ids = получаешь как тебе нужно return retrofit.getCurrentEpgList(ids) }, (chanels, epgList) -> { комбинируешь как тебе надо })

то что нужно, вот только проблемка

Cannot resolve method flatMap (lambdaExpression, lambdaExpression)

Ну да, такой флатмап есть у обсервабла и фловейбла. у сингла нету

Ну да, такой флатмап есть у обсервабла и фловейбла. у сингла нету

u menya j metodi vozvrashayut Observable

public static Observable<ChannelList> getChannels() { HashMap<String, String> pathParams = new HashMap<?); return (getContent(CHANNEL_PATH, pathParams, new TypeToken<ChannelList?) { })); }

public static Observable<EpgList> getCurrentEpgList(List<String> channelIdList) { HashMap<String, String> pathParams = new HashMap<?); pathParams.put("channelIdList", channelIdList.toString()); pathParams.put("locale", "hy_AM"); //send the right locale return getContent(EPG_PATH, pathParams, new TypeToken<EpgList?) { }); }

а какие тебе студия вообще методы показывает на getChannels

мдааааа

ERROR: S client not available

Ну да, такой флатмап есть у обсервабла и фловейбла. у сингла нету

с твоим примером разобрался, понимаю как работает, спасибо, но все равно не интуитивно как бы все

даже не знал что гуглить

и вам всем ребят тоже спасибо

а можете кто нить дать ресурсы про рх, вот только чтоб не обьяснялось какие методы есть, а вообще от а до я

Для начала научиться читать доки Rx-совские. Если понять их стиль изложения, то там все класно объясняется.

Еще и с картинками

Для начала научиться читать доки Rx-совские. Если понять их стиль изложения, то там все класно объясняется.

окей, спасибо за помощь еще раз

Кстати, у меня все на первой

сильно 2 поменялась?

чтобы перепрыгнуть быстро

Само апи почти такое же. Нулы, правда, теперь в поток паблишить нельзя.

А вообще стоит оно того?

Чтобы переходить

вообще вот здесь отличия хорошо расписаны https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0

Количество методов в финальной апк выросло. Зато производительность лучше стала.

timer deprecated overloads dropped

печаль

А вообще стоит оно того?

10k методов в RX2, против 5k RX1 - стоит подумать, стоит ли оно того ?

Интересно всегда, что-то новое :)

Правда я чет замену timer найти немогу в 2.0

Так дропнули то, что в первой задеприкейтили. А в деприкейте написано, что вместо него интервал юзать нужно

10k методов в RX2, против 5k RX1 - стоит подумать, стоит ли оно того ?

прогвард

прогвард

тормоза при сборке (мало мне что-ли gradle)

а Timer не отмеччен депрекейтид

интервал немного другое

http://reactivex.io/RxJava/1.x/javadoc/rx/Observable.html#timer(long,%20long,%20java.util.concurrent.TimeUnit) Вот этот дропнули, и следующий за ним. Они как раз интервалом заменяются.

тормоза при сборке (мало мне что-ли gradle)

Ну релизные сборки явно уж не каждые 5 минут собираются

Ну релизные сборки явно уж не каждые 5 минут собираются

А дебажить я как должен, если лимит превышен?

Multidex

Multidex

тормоза при сборке 2

Да как бы нет