The highest tagged major version is
Documentation
¶
Index ¶
- type ForwardFunc
- type 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) Forward(msg *streams.Message) error
- func (p *Pipe) ForwardToChild(msg *streams.Message, index int) error
- func (p *Pipe) OnForward(fn ForwardFunc)
- func (p *Pipe) ShouldError()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ForwardFunc ¶ added in v0.5.0
type Pipe ¶ added in v0.3.0
type Pipe struct {
// contains filtered or unexported fields
}
func (*Pipe) AssertExpectations ¶ added in v0.3.0
func (p *Pipe) AssertExpectations()
func (*Pipe) ExpectCommit ¶ added in v0.3.0
func (p *Pipe) ExpectCommit()
func (*Pipe) ExpectForward ¶ added in v0.3.0
func (p *Pipe) ExpectForward(k, v interface{})
func (*Pipe) ExpectForwardToChild ¶ added in v0.3.0
func (*Pipe) ForwardToChild ¶ added in v0.3.0
func (*Pipe) OnForward ¶ added in v0.5.0
func (p *Pipe) OnForward(fn ForwardFunc)
func (*Pipe) ShouldError ¶ added in v0.3.0
func (p *Pipe) ShouldError()
Source Files
Click to show internal directories.
Click to hide internal directories.