pipe

Documentation

Index

• type Packet
• type Pipe
  • func Map[S any, T any](original Pipe[S], encode func(T) (S, error), decode func(S) (T, error)) Pipe[T]

Types

type Packet

type Packet[T any] struct {
	Contents T
	Error    error
}

type Pipe

type Pipe[T any] interface {
	Send(data T) error
	Receive() <-chan Packet[T]
}

func Map

func Map[S any, T any](
	original Pipe[S],
	encode func(T) (S, error),
	decode func(S) (T, error),
) Pipe[T]