chmux

README

chmux

Simple in process multiplexer

Documentation

Index

• type Mux
  • func New[T any](ctx context.Context) *Mux[T]
  • func (m *Mux[T]) Close()
  • func (m *Mux[T]) CloseAllSinks()
  • func (m *Mux[T]) CloseSink(chs ...chan T)
  • func (m *Mux[T]) NewSink() chan T
  • func (m *Mux[T]) Send(t T)

Types

type Mux

type Mux[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any](ctx context.Context) *Mux[T]

func (*Mux[T]) Close

func (m *Mux[T]) Close()

func (*Mux[T]) CloseAllSinks

func (m *Mux[T]) CloseAllSinks()

func (*Mux[T]) CloseSink

func (m *Mux[T]) CloseSink(chs ...chan T)

func (*Mux[T]) NewSink

func (m *Mux[T]) NewSink() chan T

func (*Mux[T]) Send

func (m *Mux[T]) Send(t T)