Not sure if this is the best place to post, but I thought

Flow

could use a

chunked

method, just like

List

has:

fun <T> Flow<T>.chunked(size: Int) = flow {
	val list = mutableListOf<T>()
	collect {
		list.add(it)
		
		if (list.size == size) {
			emit(list.toList())
			list.clear()
		}
	}
	
	if (list.isNotEmpty())
		emit(list)
}

Might be good to include in the standard library. Loving the API 👍🏻

Adding the explicit return type would help 😉

True!

fun <T> Flow<T>.chunked(size: Int): Flow<List<T>> = flow {
    val list = mutableListOf<T>()
    collect {
        list.add(it)
        
        if (list.size == size) {
            emit(list.toList())
            list.clear()
        }
    }
    
    if (list.isNotEmpty())
        emit(list)
}