Not sure if this is the best place to post, but I thought `Flow` could use a `chunked` method, just ...

# coroutines

[nwh]

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 👍🏻

[louiscad]

Adding the explicit return type would help 😉

[nwh]

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)
}