combine two lists and map to new class object with rxjava











up vote
0
down vote

favorite












Consider the following input : Calling network call will retrieve client object



data class Client(
val name: String,
val phoneNumber: String,
val frequentContacts: List<String>,
val allContacts: List<String>
)


what i need to do is to map similar names in frequentContacts and allContacts list in new object and subscribe on the output.



assume the response from network call will return this Client Object



{
"name": "Jack",
"phoneNumber": "90284302424",
"frequentContacts": [
"John",
"Sam"
],
"allContacts": [
"John",
"Adam",
"Peter",
"Kim",
"Sam"
]
}


what i need receive in subscribe newly create object .



data class clientViewModel(val name: String,val isFrequent: Boolean)


so in onSuccess i should have instance from clientViewModel



Expected output :



("John", true")



("Adam", false")



("Peter", false")



("Kim", false")



("Sam", true")



here what i am up to



clientRepository.getClientById(clientId)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doAfterTerminate { view.hideProgress() }
.flatMap{it.frequentContacts}
.subscribe{
onSuccess(item: ClientViewModel){}
onError(){}
onFinish(){}
}


but this not work because once i used flat map i lose the allContacts list
any help ?



I read about GroupBy operator but i am using Single...










share|improve this question
























  • What do you think of: .flatMap{it.allContacts.map{c->Pair(c,it.frequentContacts.contains(c))} }
    – Raphael
    Nov 9 at 19:22












  • @Raphael i tried it shows me type miss match error Required :SingleSource <out(???)> Found : List<Pair(String, Boolean)>
    – Joe Adams
    Nov 9 at 19:51















up vote
0
down vote

favorite












Consider the following input : Calling network call will retrieve client object



data class Client(
val name: String,
val phoneNumber: String,
val frequentContacts: List<String>,
val allContacts: List<String>
)


what i need to do is to map similar names in frequentContacts and allContacts list in new object and subscribe on the output.



assume the response from network call will return this Client Object



{
"name": "Jack",
"phoneNumber": "90284302424",
"frequentContacts": [
"John",
"Sam"
],
"allContacts": [
"John",
"Adam",
"Peter",
"Kim",
"Sam"
]
}


what i need receive in subscribe newly create object .



data class clientViewModel(val name: String,val isFrequent: Boolean)


so in onSuccess i should have instance from clientViewModel



Expected output :



("John", true")



("Adam", false")



("Peter", false")



("Kim", false")



("Sam", true")



here what i am up to



clientRepository.getClientById(clientId)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doAfterTerminate { view.hideProgress() }
.flatMap{it.frequentContacts}
.subscribe{
onSuccess(item: ClientViewModel){}
onError(){}
onFinish(){}
}


but this not work because once i used flat map i lose the allContacts list
any help ?



I read about GroupBy operator but i am using Single...










share|improve this question
























  • What do you think of: .flatMap{it.allContacts.map{c->Pair(c,it.frequentContacts.contains(c))} }
    – Raphael
    Nov 9 at 19:22












  • @Raphael i tried it shows me type miss match error Required :SingleSource <out(???)> Found : List<Pair(String, Boolean)>
    – Joe Adams
    Nov 9 at 19:51













up vote
0
down vote

favorite









up vote
0
down vote

favorite











Consider the following input : Calling network call will retrieve client object



data class Client(
val name: String,
val phoneNumber: String,
val frequentContacts: List<String>,
val allContacts: List<String>
)


what i need to do is to map similar names in frequentContacts and allContacts list in new object and subscribe on the output.



assume the response from network call will return this Client Object



{
"name": "Jack",
"phoneNumber": "90284302424",
"frequentContacts": [
"John",
"Sam"
],
"allContacts": [
"John",
"Adam",
"Peter",
"Kim",
"Sam"
]
}


what i need receive in subscribe newly create object .



data class clientViewModel(val name: String,val isFrequent: Boolean)


so in onSuccess i should have instance from clientViewModel



Expected output :



("John", true")



("Adam", false")



("Peter", false")



("Kim", false")



("Sam", true")



here what i am up to



clientRepository.getClientById(clientId)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doAfterTerminate { view.hideProgress() }
.flatMap{it.frequentContacts}
.subscribe{
onSuccess(item: ClientViewModel){}
onError(){}
onFinish(){}
}


but this not work because once i used flat map i lose the allContacts list
any help ?



I read about GroupBy operator but i am using Single...










share|improve this question















Consider the following input : Calling network call will retrieve client object



data class Client(
val name: String,
val phoneNumber: String,
val frequentContacts: List<String>,
val allContacts: List<String>
)


what i need to do is to map similar names in frequentContacts and allContacts list in new object and subscribe on the output.



assume the response from network call will return this Client Object



{
"name": "Jack",
"phoneNumber": "90284302424",
"frequentContacts": [
"John",
"Sam"
],
"allContacts": [
"John",
"Adam",
"Peter",
"Kim",
"Sam"
]
}


what i need receive in subscribe newly create object .



data class clientViewModel(val name: String,val isFrequent: Boolean)


so in onSuccess i should have instance from clientViewModel



Expected output :



("John", true")



("Adam", false")



("Peter", false")



("Kim", false")



("Sam", true")



here what i am up to



clientRepository.getClientById(clientId)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doAfterTerminate { view.hideProgress() }
.flatMap{it.frequentContacts}
.subscribe{
onSuccess(item: ClientViewModel){}
onError(){}
onFinish(){}
}


but this not work because once i used flat map i lose the allContacts list
any help ?



I read about GroupBy operator but i am using Single...







kotlin rx-java2






share|improve this question















share|improve this question













share|improve this question




share|improve this question








edited Nov 12 at 8:26









Jayson Minard

36.1k14104170




36.1k14104170










asked Nov 9 at 18:56









Joe Adams

11




11












  • What do you think of: .flatMap{it.allContacts.map{c->Pair(c,it.frequentContacts.contains(c))} }
    – Raphael
    Nov 9 at 19:22












  • @Raphael i tried it shows me type miss match error Required :SingleSource <out(???)> Found : List<Pair(String, Boolean)>
    – Joe Adams
    Nov 9 at 19:51


















  • What do you think of: .flatMap{it.allContacts.map{c->Pair(c,it.frequentContacts.contains(c))} }
    – Raphael
    Nov 9 at 19:22












  • @Raphael i tried it shows me type miss match error Required :SingleSource <out(???)> Found : List<Pair(String, Boolean)>
    – Joe Adams
    Nov 9 at 19:51
















What do you think of: .flatMap{it.allContacts.map{c->Pair(c,it.frequentContacts.contains(c))} }
– Raphael
Nov 9 at 19:22






What do you think of: .flatMap{it.allContacts.map{c->Pair(c,it.frequentContacts.contains(c))} }
– Raphael
Nov 9 at 19:22














@Raphael i tried it shows me type miss match error Required :SingleSource <out(???)> Found : List<Pair(String, Boolean)>
– Joe Adams
Nov 9 at 19:51




@Raphael i tried it shows me type miss match error Required :SingleSource <out(???)> Found : List<Pair(String, Boolean)>
– Joe Adams
Nov 9 at 19:51












1 Answer
1






active

oldest

votes

















up vote
0
down vote













Honestly I'd just do this:



clientRepository.getClientById(clientId)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doFinally { view.hideProgress() }
.map { client ->
client.allContacts.map { contact ->
clientViewModel(name = contact, isFrequent = client.frequentContacts.contains(contact))
}
}
.subscribeBy(onSuccess = { list: List<clientViewModel> ->
...
}, onError = { err -> ... })





share|improve this answer





















    Your Answer






    StackExchange.ifUsing("editor", function () {
    StackExchange.using("externalEditor", function () {
    StackExchange.using("snippets", function () {
    StackExchange.snippets.init();
    });
    });
    }, "code-snippets");

    StackExchange.ready(function() {
    var channelOptions = {
    tags: "".split(" "),
    id: "1"
    };
    initTagRenderer("".split(" "), "".split(" "), channelOptions);

    StackExchange.using("externalEditor", function() {
    // Have to fire editor after snippets, if snippets enabled
    if (StackExchange.settings.snippets.snippetsEnabled) {
    StackExchange.using("snippets", function() {
    createEditor();
    });
    }
    else {
    createEditor();
    }
    });

    function createEditor() {
    StackExchange.prepareEditor({
    heartbeatType: 'answer',
    convertImagesToLinks: true,
    noModals: true,
    showLowRepImageUploadWarning: true,
    reputationToPostImages: 10,
    bindNavPrevention: true,
    postfix: "",
    imageUploader: {
    brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
    contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
    allowUrls: true
    },
    onDemand: true,
    discardSelector: ".discard-answer"
    ,immediatelyShowMarkdownHelp:true
    });


    }
    });














    draft saved

    draft discarded


















    StackExchange.ready(
    function () {
    StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53231773%2fcombine-two-lists-and-map-to-new-class-object-with-rxjava%23new-answer', 'question_page');
    }
    );

    Post as a guest















    Required, but never shown

























    1 Answer
    1






    active

    oldest

    votes








    1 Answer
    1






    active

    oldest

    votes









    active

    oldest

    votes






    active

    oldest

    votes








    up vote
    0
    down vote













    Honestly I'd just do this:



    clientRepository.getClientById(clientId)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .doFinally { view.hideProgress() }
    .map { client ->
    client.allContacts.map { contact ->
    clientViewModel(name = contact, isFrequent = client.frequentContacts.contains(contact))
    }
    }
    .subscribeBy(onSuccess = { list: List<clientViewModel> ->
    ...
    }, onError = { err -> ... })





    share|improve this answer

























      up vote
      0
      down vote













      Honestly I'd just do this:



      clientRepository.getClientById(clientId)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .doFinally { view.hideProgress() }
      .map { client ->
      client.allContacts.map { contact ->
      clientViewModel(name = contact, isFrequent = client.frequentContacts.contains(contact))
      }
      }
      .subscribeBy(onSuccess = { list: List<clientViewModel> ->
      ...
      }, onError = { err -> ... })





      share|improve this answer























        up vote
        0
        down vote










        up vote
        0
        down vote









        Honestly I'd just do this:



        clientRepository.getClientById(clientId)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .doFinally { view.hideProgress() }
        .map { client ->
        client.allContacts.map { contact ->
        clientViewModel(name = contact, isFrequent = client.frequentContacts.contains(contact))
        }
        }
        .subscribeBy(onSuccess = { list: List<clientViewModel> ->
        ...
        }, onError = { err -> ... })





        share|improve this answer












        Honestly I'd just do this:



        clientRepository.getClientById(clientId)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .doFinally { view.hideProgress() }
        .map { client ->
        client.allContacts.map { contact ->
        clientViewModel(name = contact, isFrequent = client.frequentContacts.contains(contact))
        }
        }
        .subscribeBy(onSuccess = { list: List<clientViewModel> ->
        ...
        }, onError = { err -> ... })






        share|improve this answer












        share|improve this answer



        share|improve this answer










        answered Nov 9 at 19:39









        EpicPandaForce

        46.5k14122242




        46.5k14122242






























            draft saved

            draft discarded




















































            Thanks for contributing an answer to Stack Overflow!


            • Please be sure to answer the question. Provide details and share your research!

            But avoid



            • Asking for help, clarification, or responding to other answers.

            • Making statements based on opinion; back them up with references or personal experience.


            To learn more, see our tips on writing great answers.





            Some of your past answers have not been well-received, and you're in danger of being blocked from answering.


            Please pay close attention to the following guidance:


            • Please be sure to answer the question. Provide details and share your research!

            But avoid



            • Asking for help, clarification, or responding to other answers.

            • Making statements based on opinion; back them up with references or personal experience.


            To learn more, see our tips on writing great answers.




            draft saved


            draft discarded














            StackExchange.ready(
            function () {
            StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53231773%2fcombine-two-lists-and-map-to-new-class-object-with-rxjava%23new-answer', 'question_page');
            }
            );

            Post as a guest















            Required, but never shown





















































            Required, but never shown














            Required, but never shown












            Required, but never shown







            Required, but never shown

































            Required, but never shown














            Required, but never shown












            Required, but never shown







            Required, but never shown







            Popular posts from this blog

            Schultheiß

            Verwaltungsgliederung Dänemarks

            Liste der Kulturdenkmale in Wilsdruff