我有一个函数,它接受一个模型并将其映射到一个实体。这是实体被传递到另一个返回 may 的函数中。
我不想在主线程上运行映射过程,所以我创建了一个嵌套的可能。
//Returns the id of the inserted exam
fun insertExamIntoDatabase(examModel: ExamModel): Maybe<Long> = Maybe.create { emitter ->
//Do heavy work like mapping objects
Thread.sleep(5000)
val entity = ExamMapper.toEntity(examModel)
examLocalSource.insertExam(entity).subscribe({
emitter.onSuccess(it)
}, {
emitter.onError(it)
})
这个函数有效,但它看起来不像干净的代码。此外,如果您使用较大的数据,我担心内存泄漏之类的事情。
有什么办法,我该如何改进这种方法?
感谢您的帮助。
flatMap
的完美用例:
fun insertExamIntoDatabase(examModel: ExamModel): Maybe<Long> =
Maybe.create { emitter ->
//Do heavy work like mapping objects
Thread.sleep(5000)
emitter.onSuccess(ExamMapper.toEntity(examModel))
}.flatMap { entity -> examLocalSource.insertExam(entity) }