@ExperimentalCoroutinesApi
@ExperimentalTime
fun <T> Flow<T>.bufferChunks(count: Int, maxDuration: Duration): Flow<List<T>> {
	return flow {
		coroutineScope {
			val channel = produceIn(this)
			while (!channel.isClosedForReceive) {
				val chunk = mutableListOf<T>()
				withTimeout(maxDuration) {
					for (item in channel) {
						chunk.add(item)
						if (chunk.size >= count) break
					}
				}
				emit(chunk)
			}
		}
	}
}