Skip to content

Instantly share code, notes, and snippets.

@aleksandra-majchrzak

aleksandra-majchrzak/shared_flow_observable_example.kt Secret

Created May 10, 2021 21:15
Show Gist options
  • Save aleksandra-majchrzak/b28fe520630144255d3ff7116e49f364 to your computer and use it in GitHub Desktop.
Save aleksandra-majchrzak/b28fe520630144255d3ff7116e49f364 to your computer and use it in GitHub Desktop.
Download ZIP
Example 1 for Kotlin Shared Flow article
Raw
shared_flow_observable_example.kt
fun uploadData(): Observable<UpdateStep> = Observable.create<UpdateStep> {
it.onNext(UpdateStep.Step1)
doUpdateStep1()
it.onNext(UpdateStep.Step2)
doUpdateStep2()
it.onNext(UpdateStep.Step3)
doUpdateStep3()
it.onNext(UpdateStep.Success)
}.onErrorReturn {
UpdateStep.Error(it)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment