test

Documentation

Index

• func SyncHandler() (chan<- message.HandlerFunc, message.Handler)
• type Env
  • func NewEnv(t *testing.T) *Env
  • func (a *Env) Close()
  • func (a *Env) CloseClient(client *message.Broker) error
  • func (a *Env) Register(funcs ...message.New)
  • func (a *Env) Start()
  • func (a *Env) StartClient(client *message.Broker) (*message.Conn, error)

Functions

func SyncHandler

func SyncHandler() (chan<- message.HandlerFunc, message.Handler)

Types

type Env

type Env struct {
	T      *testing.T
	Broker *message.Broker
	// contains filtered or unexported fields
}

func NewEnv

func NewEnv(t *testing.T) *Env

func (*Env) Close

func (a *Env) Close()

func (*Env) CloseClient

func (a *Env) CloseClient(client *message.Broker) error

func (*Env) Register

func (a *Env) Register(funcs ...message.New)

func (*Env) Start

func (a *Env) Start()

func (*Env) StartClient

func (a *Env) StartClient(client *message.Broker) (*message.Conn, error)