Only complete the worker's scope after calling Worker.onStop

nourbt · May 15, 2023 · e81100f · e81100f
1 parent a815d85
commit e81100f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/android/libraries/rib-base/src/main/kotlin/com/uber/rib/core/WorkerBinder.kt b/android/libraries/rib-base/src/main/kotlin/com/uber/rib/core/WorkerBinder.kt
@@ -333,14 +333,14 @@ private fun <T : Comparable<T>> Worker.bind(
       lifecycle
         .takeWhile { it < lifecycleRange.endInclusive }
         .onCompletion {
-          completable.onComplete()
           bindAndReportWorkerInfo(
             workerDurationListenerWeakRef,
             WorkerEvent.STOP,
             coroutineContext,
           ) {
             onStop()
           }
+          completable.onComplete()
         }
         .collect {
           bindAndReportWorkerInfo(