pipe

package
v0.0.33 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 20, 2024 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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(context.Context, T) (V, error)

func (Func[T, V]) Execute

func (f Func[T, V]) Execute(ctx context.Context, source T) (V, error)

type IO

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

type ToWriter

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL