hi guys, in my viewmodel, I have n observables who...

# rx

[ursus]

hi guys, in my viewmodel, I have n observables whose emits come from another thread, and the last one's come from main thread

Observables
                .combineLatest(
                        callStateManager.callStateObservable(),
                        callStateManager.callDurationObservable().map(::formatTime),
                        callStateManager.audioRouteObservable(),
                        callStateManager.micMutedObservable(),
                        callStateManager.videoMutedObservable(),
                        pipManager.inPipObservable,
                        ::mapState)
                .observeOn(AndroidSchedulers.mainThread())

so when pipManager emits (driven by Activity.onPipModeChanged), it will only ever be from main thread, so there is no reason to post it, however I do need a post for the callStateManager observables

is something like this a stupid idea?

Observables.combineLatest(
	callStateManager.callStateObservable().observeOn(AndroidSchedulers.mainThread()),
	callStateManager.callDurationObservable().map(::formatTime).observeOn(AndroidSchedulers.mainThread()),
	callStateManager.audioRouteObservable().observeOn(AndroidSchedulers.mainThread()),
	callStateManager.micMutedObservable().observeOn(AndroidSchedulers.mainThread()),
	callStateManager.videoMutedObservable().observeOn(AndroidSchedulers.mainThread()),
	pipManager.inPipObservable,
	::mapState)

(without the observeOn as last operator)