pipe

Aug 15, 2017

Changes in this version

+ var ErrUnableToListen = errors.New("Listen called without a nil In chan")

+ type TrackedMessage struct

+ Msg message.Msg

+ Off offset.Offset

Mar 7, 2017

Changes in this version

+ type Mock struct

+ MsgCount int

+ func (m *Mock) WriteMessage(msg message.Msg) (message.Msg, error)

+ type Pipe struct

+ Err chan error

+ Event chan events.Event

+ ExtraState map[string]interface{}

+ In messageChan

+ LastMsg message.Msg

+ MessageCount int

+ Out []messageChan

+ Stopped bool

+ func NewPipe(pipe *Pipe, path string) *Pipe

+ func (m *Pipe) Listen(fn func(message.Msg) (message.Msg, error), nsFilter *regexp.Regexp) error

+ func (m *Pipe) Send(msg message.Msg)

+ func (m *Pipe) Stop()