stream

Documentation

Index

• type CB
• type Stream
  • func NewStream() *Stream
  • func (this *Stream) Go(arg interface{}) (interface{}, error)
  • func (this *Stream) Next(cb CB) *Stream

Types

type CB

type CB func(interface{}) (interface{}, error)

定回调函数指针的类型

type Stream

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

任务节点结构定义

func NewStream

func NewStream() *Stream

* 创建新的流 *

func (*Stream) Go

func (this *Stream) Go(arg interface{}) (interface{}, error)

* 流结束 arg为流初始参数，初始参数放在End方法中是考虑到初始参数不需在任务链中传递 *

func (*Stream) Next

func (this *Stream) Next(cb CB) *Stream