|
1 | 1 | package org.stepik.android.domain.course_content.interactor |
2 | 2 |
|
3 | | -import com.google.firebase.perf.FirebasePerformance |
4 | 3 | import io.reactivex.Observable |
5 | 4 | import io.reactivex.Single |
6 | 5 | import io.reactivex.rxkotlin.Observables |
7 | 6 | import io.reactivex.rxkotlin.Singles.zip |
8 | 7 | import io.reactivex.rxkotlin.toObservable |
9 | 8 | import io.reactivex.schedulers.Schedulers |
10 | 9 | import io.reactivex.subjects.PublishSubject |
11 | | -import org.stepic.droid.analytic.AmplitudeAnalytic |
12 | | -import org.stepic.droid.analytic.Analytic |
13 | 10 | import ru.nobird.app.core.model.mapToLongArray |
14 | 11 | import org.stepic.droid.util.plus |
15 | 12 | import org.stepik.android.domain.base.DataSourceType |
@@ -74,21 +71,12 @@ constructor( |
74 | 71 | private fun getEmptySections(course: Course): Observable<Pair<Course, List<CourseContentItem>>> = |
75 | 72 | Observable.just(course to emptyList()) |
76 | 73 |
|
77 | | - private fun getContent(course: Course, items: List<CourseContentItem>, dataSourceType: DataSourceType): Observable<Pair<Course, List<CourseContentItem>>> { |
78 | | - val courseContentLoadingTrace = FirebasePerformance.getInstance().newTrace(Analytic.Traces.COURSE_CONTENT_LOADING) |
79 | | - courseContentLoadingTrace.putAttribute(AmplitudeAnalytic.Course.Params.COURSE, course.id.toString()) |
80 | | - courseContentLoadingTrace.putAttribute(AmplitudeAnalytic.Course.Params.SOURCE, dataSourceType.name) |
81 | | - courseContentLoadingTrace.start() |
82 | | - |
83 | | - return getSectionsOfCourse(course, dataSourceType) |
| 74 | + private fun getContent(course: Course, items: List<CourseContentItem>, dataSourceType: DataSourceType): Observable<Pair<Course, List<CourseContentItem>>> = |
| 75 | + getSectionsOfCourse(course, dataSourceType) |
84 | 76 | .flatMap { populateSections(course, it, items, dataSourceType) } |
85 | 77 | .flatMapObservable { populatedItems -> |
86 | 78 | Observable.just(course to populatedItems) + loadUnits(course, populatedItems, dataSourceType) |
87 | 79 | } |
88 | | - .doOnComplete { |
89 | | - courseContentLoadingTrace.stop() |
90 | | - } |
91 | | - } |
92 | 80 |
|
93 | 81 | private fun getSectionsOfCourse(course: Course, dataSourceType: DataSourceType): Single<List<Section>> = |
94 | 82 | sectionRepository |
|
0 commit comments