mocks

Jun 10, 2021

Changes in this version

+ type Predicate struct

+ func (_m *Predicate) Assert(_a0 streams.Message) (bool, error)

Jun 1, 2021

Changes in this version

+ const Anything

+ type ChildMessage struct

+ Index int

+ Msg streams.Message

+ type Pipe struct

+ func NewPipe(t *testing.T) *Pipe

+ func (p *Pipe) AssertExpectations()

+ func (p *Pipe) Commit(msg streams.Message) error

+ func (p *Pipe) ExpectCommit()

+ func (p *Pipe) ExpectForward(k, v interface{})

+ func (p *Pipe) ExpectForwardToChild(k, v interface{}, index int)

+ func (p *Pipe) ExpectMark(k, v interface{})

+ func (p *Pipe) Forward(msg streams.Message) error

+ func (p *Pipe) ForwardToChild(msg streams.Message, index int) error

+ func (p *Pipe) Mark(msg streams.Message) error

+ func (p *Pipe) Messages() []ChildMessage

+ func (p *Pipe) ShouldError()

+ type Source struct

+ func NewSource(msgs []streams.Message, expectedCommitCount int) *Source

+ func (s *Source) Close() error

+ func (s *Source) Commit(interface{}) error

+ func (s *Source) Consume() (streams.Message, error)

+ func (s *Source) Wait(timeout time.Duration)