then ``` fun refresh() { callTheApi() ...

# android-architecture

[ursus]

then

fun refresh() {
        callTheApi()
            .flatMap( insertNewDataToDb ) <------------- queryDataObservable emits automatically after this line
            .map {Status.SUCCESS}
            .startWith(Status.STARTED)
            .subscribe(statusRelay)
    }