goroutine with pipeline

go-pipeline

package main

import (
	"fmt"
)

func main() {
	data := []int{1, 2, 3, 4}
	// data |> time |> plus
	ret := plus(time(data))
	fmt.Println(ret)
}

func time(data []int) (c chan int) {
	c = make(chan int)
	go func() {
		defer close(c)
		for _, v := range data {
			c <- v * 2
		}
	}()
	return
}

func plus(data chan int) (ret []int) {
	for n := range data {
		ret = append(ret, n+1)
	}
	return
}