feat: added a simple emitter

deliveryhero · Apr 13, 2021 · 3ab8ad6 · 3ab8ad6
1 parent 3089fc9
commit 3ab8ad6
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/emit.go b/emit.go
@@ -0,0 +1,13 @@
+package util
+
+// Emit fans is out into a channel
+func Emit(is ...interface{}) <-chan interface{} {
+	out := make(chan interface{})
+	go func() {
+		defer close(out)
+		for _, i := range is {
+			out <- i
+		}
+	}()
+	return out
+}