feat(streams): implement skip operator

Author: DerYeger

.changeset/twelve-things-notice.md

@@ -0,0 +1,5 @@
+---
+'@yeger/streams': minor
+---
+
+implement skip operator

packages/streams/src/async.ts

@@ -451,6 +451,22 @@ export function zip<T, R>(other: MaybeAsyncIterable<R>): AsyncOperator<T, [T, R]
     })
 }
 
+/**
+ * Skips the first n items from the source.
+ */
+export function skip<T>(n: number): AsyncOperator<T, T> {
+  return (source: AsyncIterable<T>) =>
+    createAsyncIterable(async function* (): AsyncIterableIterator<T> {
+      let skipped = 0
+      for await (const item of source) {
+        if (skipped++ < n) {
+          continue
+        }
+        yield item
+      }
+    })
+}
+
 /**
  * Emits at most the first n items from the source.
  */

packages/streams/src/sync.ts

@@ -423,6 +423,22 @@ export function zip<T, R>(other: Iterable<R>): Operator<T, [T, R]> {
     })
 }
 
+/**
+ * Skips the first n items from the source.
+ */
+export function skip<T>(n: number): Operator<T, T> {
+  return (source: Iterable<T>) =>
+    createIterable(function* (): IterableIterator<T> {
+      let skipped = 0
+      for (const item of source) {
+        if (skipped++ < n) {
+          continue
+        }
+        yield item
+      }
+    })
+}
+
 /**
  * Emits at most the first n items from the source.
  */