pipeline

Documentation

Index

• type Pipeline
  • func New[T any]() Pipeline[T]

Types

type Pipeline

type Pipeline[T any] interface {
	Send(T) Pipeline[T]
	Through(middlewares ...func(t T, next func())) Pipeline[T]
	Then(func(T))
}

func New

func New[T any]() Pipeline[T]