Add Pipeline #125

README.md

@@ -152,6 +152,7 @@ Other functional programming helpers:
 - ToSlicePtr
 - Empty
 - Coalesce
+- Pipeline
 
 Concurrency helpers:
 
@@ -1357,6 +1358,19 @@ result, ok := lo.Coalesce[*string](nil, nilStr, &str)
 // &"foobar" true
 ```
 
+### Pipeline
+
+ Pipeline takes a list of functions and returns a function that takes a value as its argument and runs it through a pipeline of the original functions given in this function.
+```go
+	cb := func(x int) int { return x * x * x }
+	tp := func(x int) int { return 3 * x }
+	db := func(x int) int { return 2 * x }
+	f := Pipeline(cb, tp, db)
+
+	f(5)
+	// 750
+```
+
 ### Attempt
 
 Invokes a function N times until it returns valid output. Returning either the caught error or nil. When first argument is less than `1`, the function runs until a sucessfull response is returned.

func.go

@@ -0,0 +1,14 @@
+package lo
+
+// Pipeline takes a list of functions and returns a function
+// that takes a value as its argument and runs it through
+// a pipeline of the original functions given in this function.
+func Pipeline[T any](funcs ...func(T) T) func(T) T {
+	return func(t T) (result T) {
+		result = t
+		for _, f := range funcs {
+			result = f(result)
+		}
+		return
+	}
+}

func_test.go

@@ -0,0 +1,17 @@
+package lo
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestPipeline(t *testing.T) {
+	is := assert.New(t)
+
+	cb := func(x int) int { return x * x * x }
+	tp := func(x int) int { return 3 * x }
+	db := func(x int) int { return 2 * x }
+	f := Pipeline(cb, tp, db)
+	is.Equal(750, f(5))
+}