line

Sep 16, 2021

Changes in this version

type Option

+ func WithName(name string) Option

Sep 7, 2021

Changes in this version

type CallCtx

+ func NewCallCtx(call CallFn, param interface{}) *CallCtx

+ type CallFn func(ctx context.Context, req interface{}) (rsp interface{}, err error)

Sep 7, 2021

Changes in this version

+ type AsyncCtx struct

+ func NewAsyncCtx(ctx context.Context, ...) *AsyncCtx

+ func (m *AsyncCtx) R() (interface{}, error)

+ func (m *AsyncCtx) SetR(r interface{}, err error)

+ type AsyncR struct

+ type CallCtx struct

+ Call func(ctx context.Context, req interface{}) (rsp interface{}, err error)

+ Param interface{}

+ type Line struct

+ func NewLine(wg *sync.WaitGroup, opts ...Option) *Line

+ func (c *Line) AsyncCall(ctx context.Context, callCtx *CallCtx) (interface{}, error)

+ func (c *Line) QSize() int

+ func (c *Line) Run()

+ func (c *Line) Stop()

+ type Option func(option *_Option)

+ func WithQSize(qSize int) Option