feat: add EmptyStream

sharpvik · Oct 8, 2024 · 0539ba7 · 0539ba7
1 parent 45c42f1
commit 0539ba7
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/errstream.go b/errstream.go
@@ -1,9 +1,15 @@
 package fungi
 
+import "io"
+
 func ErrorStream[T any](err error) Stream[T] {
 	return &errorStream[T]{err}
 }
 
+func EmptyStream[T any]() Stream[T] {
+	return ErrorStream[T](io.EOF)
+}
+
 type errorStream[T any] struct {
 	err error
 }