कोटलिन में फ़्लोएबल का उपयोग करके एकाधिक रेट्रोफिट2 अनुरोध

कोटलिन, आरएक्स, रेट्रोफिट2 में अपने कौशल में सुधार करने के लिए मैंने एक डेमो प्रोजेक्ट करने का फैसला किया है। डेमो प्रोजेक्ट में पोस्ट को रिसाइकलर व्यू में प्रदर्शित करना होता है और फिर पोस्ट के विवरण को विस्तृत गतिविधि में प्रदर्शित करना होता है।
मुझे विभिन्न एपीआई कॉल से आने वाले डेटा को प्रदर्शित करने में कठिनाइयों का सामना करना पड़ा: उपयोगकर्ता नाम, शीर्षक, पोस्ट का मुख्य भाग और पोस्ट की टिप्पणियों की संख्या।

मेरी समस्या यह है कि मैं कई अनुरोध करना चाहता हूं और फिर उन्हें विस्तार गतिविधि में प्रदर्शित करने के लिए आवश्यक सभी डेटा प्राप्त करना है। जिसका अर्थ है एक कॉल करना जो मुझे उपयोगकर्ता नाम देता है और फिर एक कॉल जो मुझे पोस्ट के लिए टिप्पणियों की संख्या देता है। शीर्षक और पोस्ट का मुख्य भाग मुख्य गतिविधि में किए गए अनुरोध से आ रहा है, मैं इसे बंडल के साथ विस्तार गतिविधि में प्रेषित करता हूं।

एपीआई कॉल:
// पोस्ट के लिए टिप्पणियां लौटाएं 1
http://jsonplaceholder.typicode.com/comments?postId=1

// उपयोगकर्ता की जानकारी लौटाएं 2
http://jsonplaceholder.typicode.com/users/2

// मुख्य गतिविधि में पोस्ट प्रदर्शित करने के लिए उपयोग की जाने वाली कॉल
http://jsonplaceholder.typicode.com/posts

मैं अभी भी आरएक्स पर नया हूं, मैं एक फ्लैट मैप का उपयोग करने के बारे में सोच रहा था लेकिन मुझे नहीं पता कि कोटलिन में फ्लोएबल के साथ इसका उपयोग कैसे किया जाए ..

var post = viewModel.getPost()
var userStream: Flowable<User> = postService.getUser(post.userId)
var commentsByPostIdCall: Flowable<List<Comment>> = postService.getCommentsByPostId(post.id)

userStream.subscribeOn(Schedulers.io())
        .subscribe(object : Subscriber<User> {
            override fun onError(t: Throwable?) {
                Log.d(this.toString(), " Read of users failed with the following message: " + t?.message);
            }

            override fun onNext(user: User) {
                userTextView.text = user.name
                title.text = post.title
                body.text = post.body
            }

            override fun onComplete() {
            }

            override fun onSubscribe(s: Subscription?) {
                if (s != null) {
                    s.request(1)
                }
            }
        })

मैंने दूसरी कॉल को getNumberComments विधि में रखा है:

    private fun getNumberComments(commentsByPostIdCall: Flowable<List<Comment>>): Int {
    var listComments = listOf<Comment>()
    var listCommentSize = 0

     commentsByPostIdCall
             .subscribeOn(Schedulers.io())
             .subscribe(object : Subscriber<List<Comment>> {
                override fun onError(t: Throwable?) {
                    Log.d(this.toString(), " Read of comments failed with the following message: " + t?.message);
                }

                override fun onNext(comment: List<Comment>) {
                    listComments = comment
                }

                override fun onComplete() {
                    print("onComplete!")
                    listCommentSize = listComments.size
                }

                override fun onSubscribe(s: Subscription?) {
                    if (s != null) {
                        s.request(1)
                    }
                }
            })
    return listCommentSize

}

अन्य सोचते हैं कि मैंने देखा है कि कभी-कभी स्ट्रीम पूर्ण नहीं होती है, कभी-कभी यह अगला पर अवरुद्ध रहती है। समझ में नहीं आता क्यों?

किसी भी मदद की बहुत सराहना की जाएगी! बहुत - बहुत धन्यवाद :)