listenerswitch

Documentation

Index

• Constants
• type ListenerSwitch
  • func New(size int, in <-chan any, errHandler any, handlers ...any) (*ListenerSwitch, error)
  • func (ls *ListenerSwitch) Handle(i any) (any, error)
  • func (ls *ListenerSwitch) Run()
  • func (ls *ListenerSwitch) SetErrorHandler(i any) (err error)
  • func (ls *ListenerSwitch) SetIn(in <-chan interface{})

Constants

const (
	ErrRegisterMuxHandler = lerr.Str("handler argument to RegisterMuxHandler requires a func or a channel")
)

Types

type ListenerSwitch

type ListenerSwitch struct {
	*handler.Switch
	lerr.ErrHandler
	// contains filtered or unexported fields
}

ListenerSwitch takes objects off a channel and passes them into the handlers for that type.

func New

func New(size int, in <-chan any, errHandler any, handlers ...any) (*ListenerSwitch, error)

New creates a ListenerSwitch for the in bus channel.

func (*ListenerSwitch) Handle

func (ls *ListenerSwitch) Handle(i any) (any, error)

func (*ListenerSwitch) Run

func (ls *ListenerSwitch) Run()

Run the ListenerSwitch. It will stop running when the channel is closed.

func (*ListenerSwitch) SetErrorHandler

func (ls *ListenerSwitch) SetErrorHandler(i any) (err error)

func (*ListenerSwitch) SetIn

func (ls *ListenerSwitch) SetIn(in <-chan interface{})

SetIn sets the interface channel the ListerMux is listening on.