multiplexer

Documentation

Index

• type FuncWrite
• type Message
• type MixStdOutErr
  • func New[T comparable](r io.Reader, w io.Writer) MixStdOutErr[T]

Types

type FuncWrite

type FuncWrite func(p []byte) (n int, err error)

type Message

type Message[T comparable] struct {
	Stream  T      `cbor:"1,keyasint"`
	Message []byte `cbor:"2,keyasint"`
}

type MixStdOutErr

type MixStdOutErr[T comparable] interface {
	io.Reader

	Writer(key T) io.Writer
	Add(key T, fct FuncWrite)
}

func New

func New[T comparable](r io.Reader, w io.Writer) MixStdOutErr[T]