pipeline

Documentation

Index

• type MessageContext
• type Pipeline
  • func New(rwc io.ReadWriteCloser, container handler.Container) (pipe *Pipeline, r *reactor.Stream)
  • func (p *Pipeline) OnRx(data []byte)
  • func (p *Pipeline) Tx(data interface{}) (err error)

Types

type MessageContext

type MessageContext struct {
	// contains filtered or unexported fields
}

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

func New

func New(rwc io.ReadWriteCloser, container handler.Container) (pipe *Pipeline, r *reactor.Stream)

func (*Pipeline) OnRx

func (p *Pipeline) OnRx(data []byte)

func (*Pipeline) Tx

func (p *Pipeline) Tx(data interface{}) (err error)