15 lines
205 B
Go
15 lines
205 B
Go
package pipeline
|
|
|
|
func Pipe[In any, Out any](in <-chan In, pipe func(In) Out) <-chan Out {
|
|
out := make(chan Out)
|
|
|
|
go func() {
|
|
for n := range in {
|
|
out <- pipe(n)
|
|
}
|
|
close(out)
|
|
}()
|
|
|
|
return out
|
|
}
|