chanOutput

func (*Ctx) Close ¶

func (c *Ctx) Close() error

Close 关闭管道输出上下文，注意：不保证协程安全，需调用方自行判断，new以后若要关闭，需要确定已经没有协程在调用Output，然后才能调用

func (*Ctx) GetChanCap ¶

func (c *Ctx) GetChanCap() int

GetChanCap 获取管道的最大大小

func (*Ctx) GetChanCurUsed ¶

func (c *Ctx) GetChanCurUsed() int

GetChanCurUsed 获取管道当前占用情况

func (*Ctx) GetSingleOutObj ¶

func (c *Ctx) GetSingleOutObj() (*outputable.OutObj, bool)

GetSingleOutObj 从管道中取出一个输出对象

func (*Ctx) Log ¶

func (c *Ctx) Log(_ *outputable.Log) error

func (*Ctx) Output ¶

func (c *Ctx) Output(obj *outputable.OutObj) error

Output 向管道推送一个OutObj

func (*Ctx) OutputChan ¶

func (c *Ctx) OutputChan() <-chan *outputable.OutObj

OutputChan 获取当前ctx的输出管道（只读）