TimerFlow.kt

class TimerFlow {
    @ExperimentalCoroutinesApi
    suspend fun timer(
            pollingDelay: Long,
            coroutineDispatcher: CoroutineDispatcher = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
    ) = flow {
        while (true) {
            delay(pollingDelay)
            emit(Unit)
        }
    }.flowOn(coroutineDispatcher)
}