pipe

Documentation

Index

• func Lift[P c.Pipeline[T, V], T, V any](pipeline P) tdl.Pipeline[T, V]
• type FromFs
• type FromInput
• type FromReader
• type Func
  • func Map[A c.Pipeline[T, V], T, V, X, Y any](p A, f func(X, Y) (T, V)) Func[X, Y]
  • func MapA[PA c.Pipeline[A, T], A, B, T any](p PA, f func(B) A) Func[B, T]
  • func MapB[PA c.Pipeline[T, A], A, B, T any](p PA, f func(B) A) Func[T, B]
  • func (f Func[T, V]) Execute(source T, sink V) error
• type IO
• type ToSink
• type ToWriter

Functions

func Lift

func Lift[
	P c.Pipeline[T, V],
	T, V any,
](pipeline P) tdl.Pipeline[T, V]

Types

type FromFs

type FromFs[T any] Func[afero.Fs, T]

type FromInput

type FromInput[T any] Func[tdl.Input, T]

type FromReader

type FromReader[T any] Func[io.Reader, T]

type Func

type Func[T, V any] func(T, V) error

func Map

func Map[
	A c.Pipeline[T, V],
	T, V, X, Y any,
](p A, f func(X, Y) (T, V)) Func[X, Y]

func MapA

func MapA[
	PA c.Pipeline[A, T],
	A, B, T any,
](p PA, f func(B) A) Func[B, T]

func MapB

func MapB[
	PA c.Pipeline[T, A],
	A, B, T any,
](p PA, f func(B) A) Func[T, B]

func (Func[T, V]) Execute

func (f Func[T, V]) Execute(source T, sink V) error

type IO

type IO Func[io.Reader, io.Writer]

type ToSink

type ToSink[T any] Func[T, tdl.Sink]

type ToWriter

type ToWriter[T any] Func[T, io.Writer]