Fix overflow bug in Flow.drop

Eduard Wolf · qwwdfsad · commit e35637a9faab · 2019-05-20T14:31:48.000+03:00
diff --git a/kotlinx-coroutines-core/common/src/flow/operators/Limit.kt b/kotlinx-coroutines-core/common/src/flow/operators/Limit.kt
@@ -23,7 +23,7 @@ public fun <T> Flow<T>.drop(count: Int): Flow<T> {
     return flow {
         var skipped = 0
         collect { value ->
-            if (++skipped > count) emit(value)
+            if (skipped >= count) emit(value) else ++skipped
         }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@ public fun <T> Flow<T>.drop(count: Int): Flow<T> {`
`23`	`23`	`return flow {`
`24`	`24`	`var skipped = 0`
`25`	`25`	`collect { value ->`
`26`		`- if (++skipped > count) emit(value)`
	`26`	`+ if (skipped >= count) emit(value) else ++skipped`
`27`	`27`	`}`
`28`	`28`	`}`
`29`	`29`	`}`