These are chat archives for ReactiveX/RxJava

19th
Apr 2016
Pieter Vos
@Kentaree
Apr 19 2016 09:32
Hi guys
I'm trying to figure out the best way of combining 2 observables in sequence
I have an existing observable, and I want to essentially return its values after another piece of code has been successfully executed
but I'm drawing a blank
Nam Nguyen Hoai
@eneim
Apr 19 2016 09:48

Pardon me if posting this is not allowed here: https://github.com/google/agera

But google seems to have some individual implementation for Android. Any ideas?

Dorus
@Dorus
Apr 19 2016 10:14
@Kentaree Please clarify. You want to run 2 observable simultaneous (merge), run one after the other (concat), run new observables concurrent based on the values of another one (flatMap) or run new observables serial based on the values of another one (concatMap)
Actually flatMap = mergeMap, this even used to be an alias but i think now there's only flatMap .
Pieter Vos
@Kentaree
Apr 19 2016 10:15
@Dorus one after the other, I've just implemented it using concat which seems to be the most suitable one, thanks :)
Dorus
@Dorus
Apr 19 2016 10:15
Sounds perfect
This message was deleted
Alexander Dorfman
@alexander-dorfman
Apr 19 2016 22:27
Hi !
I am absolutely new to RxJava and have a small problem that I can't resolve.
Dorus
@Dorus
Apr 19 2016 22:35
@newprint We've been working with Rx for some time and know a bit more about it. However i'm afraid you did not tell us enough about the problem to give you any hints :)
Alexander Dorfman
@alexander-dorfman
Apr 19 2016 22:35
give me a sec, I will describe a problem
Lalit Maganti
@tilal6991
Apr 19 2016 22:49
@eneim if you look at the issues you'll see one of the main devs posted a difference between it and rxjava
Alexander Dorfman
@alexander-dorfman
Apr 19 2016 22:51

Here is my problem
I have two classes, RAnalyticsEngine - http://pastebin.com/iZFC4DHv
and second class RAnalyticsServiceImp - http://pastebin.com/9ZtDLb7Q

Notice that RAnalyticsServiceImp creates Observable<RAnalyticsEngine > in line 60

I suspect, that I don't create Observable<RAnalyticsEngine > correctly, since .create() method is never being called.
.create method initializes some of the parts of RAnalyticsEngine.
So, main problem is, how to correctly create Observable<RAnalyticsEngine > from within RAnalyticsServiceImp?
Alexander Dorfman
@alexander-dorfman
Apr 19 2016 23:19
Thank you for any help !