ensuring that the startSync emits an initial value to signifying its running

This commit is contained in:
Adam Brown 2022-03-13 18:54:00 +00:00
parent 7fff5face4
commit 4fb6535310
1 changed files with 1 additions and 0 deletions

View File

@ -89,6 +89,7 @@ internal class DefaultSyncService(
}
}
.onStart {
emit(Unit)
val subscriptions = syncSubscriptionCount.incrementAndGet()
logger.matrixLog(MatrixLogTag.SYNC, "flow onStart - count: $subscriptions")
}