I'm looking to re-emit the last search result when refresh() is called. What I have below works, but...

# coroutines

[Ben]

I'm looking to re-emit the last search result when refresh() is called. What I have below works, but is there a nicer way of doing it? (More specifically, I found the apply block for the refreshChannel was necessary for the resultStream to emit at all, but it doesn't feel right).

private val searchQueryStream = MutableStateFlow<String>("")

private val refreshChannel = Channel<Unit>(Channel.CONFLATED).apply { offer(Unit) }

val resultStream: Flow<PagingData<TenorGifTileData>> =
    searchQueryStream
        .combine(refreshChannel.receiveAsFlow()) { queryStream, _ -> queryStream }
        .filter { searchQuery ->
            searchQuery.query.isNotEmpty()
        }
        .flatMapLatest { searchQuery ->
            repository.resultsForSearchQuery(searchQuery)
        }

fun refresh() {
    if (!refreshChannel.isClosedForSend) {
        refreshChannel.offer(Unit)
    }
}

[ursus]

I'd turn the refresh trigger into a MutableSharedFlow with a starting value

and on refresh just emit Unit into it