`fun dataEmissions() : Observable<YourData>(...

# rx

[zak.taccardi]

fun dataEmissions() : Observable<YourData>() and fun executeNetworkRequest(params: Params) (note 2nd method returns void).

[juliocbcotta]

zak.taccardi: So I would have a PublishSuject subject in the repository and return it in the dataEmissions() method and in the executeNetworkRequest() I would have something like service.get().subscribe(subject) ?

[zak.taccardi]

yes

[zak.taccardi]

you would need logic to ignore creating new network calls while one is already running though

[juliocbcotta]

😕

[juliocbcotta]

that is what I would like to avoid