pipeline

README

pipeline

Package pipeline allows you to use the Pipeline pattern in your processes.

Install

go get github.com/weiwenchen2022/pipeline

Examples

package main

import (
	"fmt"

	"github.com/weiwenchen2022/pipeline"
)

func main() {
	sq := func(in any) any {
		n := in.(int)
		return n * n
	}
	result := pipeline.New(2, 3).
		Through(pipeline.StageFunc(sq)).Out()
	for v := range result {
		fmt.Println(v)
	}
	// Output:
	// 4
	// 9
}

Spec

GoDoc: https://godoc.org/github.com/weiwenchen2022/pipeline

Documentation

Overview

Example

package main

import (
	"fmt"

	"github.com/weiwenchen2022/pipeline"
)

func main() {
	sq := func(in any) any {
		n := in.(int)
		return n * n
	}
	result := pipeline.New(2, 3).
		Through(pipeline.StageFunc(sq)).Out()
	for v := range result {
		fmt.Println(v)
	}
}

Output:

4
9

Index

• type Pipeline
  • func New(a ...any) *Pipeline
  • func (p *Pipeline) Out() <-chan any
  • func (p *Pipeline) Through(stages ...Stage) *Pipeline
• type Stage
• type StageFunc
  • func (f StageFunc) Handle(in any) any

Examples

• Package

Types

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

func New

func New(a ...any) *Pipeline

func (*Pipeline) Out

func (p *Pipeline) Out() <-chan any

func (*Pipeline) Through

func (p *Pipeline) Through(stages ...Stage) *Pipeline

type Stage

type Stage interface {
	Handle(any) any
}

type StageFunc

type StageFunc func(in any) any

func (StageFunc) Handle

func (f StageFunc) Handle(in any) any