Skip to content

Instantly share code, notes, and snippets.

@PatilShreyas

PatilShreyas/TimeChunkedFlow.kt Secret

Last active October 21, 2023 16:06
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save PatilShreyas/2580aed71790ae776788e54a0cc10ed1 to your computer and use it in GitHub Desktop.
Save PatilShreyas/2580aed71790ae776788e54a0cc10ed1 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
TimeChunkedFlow.kt
private class TimeChunkedFlow<T>(
private val upstream: Flow<T>,
private val duration: Duration
) : Flow<List<T>> {
override suspend fun collect(collector: FlowCollector<List<T>>) {
// TODO: implement
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment