testmessagebus

Documentation

Index

• type TestMessageBus
  • func NewTestMessageBus(t *testing.T) *TestMessageBus
  • func (mb *TestMessageBus) MustRegister(p core.MessageType, handler core.MessageHandler)
  • func (mb *TestMessageBus) NewPlayer(ctx context.Context, reader io.Reader) (core.MessageBus, error)
  • func (mb *TestMessageBus) NewRecorder(ctx context.Context) (core.MessageBus, error)
  • func (mb *TestMessageBus) ReRegister(p core.MessageType, handler core.MessageHandler)
  • func (mb *TestMessageBus) Register(p core.MessageType, handler core.MessageHandler) error
  • func (mb *TestMessageBus) Send(ctx context.Context, m core.Message, ops *core.MessageSendOptions) (core.Reply, error)
  • func (mb *TestMessageBus) WriteTape(ctx context.Context, writer io.Writer) error

Types

type TestMessageBus

type TestMessageBus struct {
	PulseNumber core.PulseNumber
	// contains filtered or unexported fields
}

func NewTestMessageBus

func NewTestMessageBus(t *testing.T) *TestMessageBus

func (*TestMessageBus) MustRegister

func (mb *TestMessageBus) MustRegister(p core.MessageType, handler core.MessageHandler)

func (*TestMessageBus) NewPlayer

func (mb *TestMessageBus) NewPlayer(ctx context.Context, reader io.Reader) (core.MessageBus, error)

func (*TestMessageBus) NewRecorder

func (mb *TestMessageBus) NewRecorder(ctx context.Context) (core.MessageBus, error)

func (*TestMessageBus) ReRegister

func (mb *TestMessageBus) ReRegister(p core.MessageType, handler core.MessageHandler)

func (*TestMessageBus) Register

func (mb *TestMessageBus) Register(p core.MessageType, handler core.MessageHandler) error

func (*TestMessageBus) Send

func (mb *TestMessageBus) Send(ctx context.Context, m core.Message, ops *core.MessageSendOptions) (core.Reply, error)

func (*TestMessageBus) WriteTape

func (mb *TestMessageBus) WriteTape(ctx context.Context, writer io.Writer) error