continuation

Documentation

Index

• Variables
• type Continuation
  • func New(segments ...Segment) *Continuation
  • func (c *Continuation) Call(local interface{}) (*Frame, error)
  • func (c *Continuation) CallStep(step int, local interface{}) (*Frame, error)
  • func (c *Continuation) Dump(frame *Frame) ([]byte, error)
  • func (c *Continuation) NewFrame(step int, local interface{}) *Frame
  • func (c *Continuation) Restore(data []byte) error
  • func (c *Continuation) Resume(frame *Frame)
  • func (c *Continuation) Segment(segment Segment) *Continuation
  • func (c *Continuation) Sleep(frame *Frame) (result interface{}, err error)
  • func (c *Continuation) Wait(frame *Frame) (status FrameMessage, result interface{}, err error)
• type Frame
  • func (f *Frame) IsDone() bool
  • func (f *Frame) Local() interface{}
  • func (f *Frame) Next(value interface{})
  • func (f *Frame) Return(value interface{})
  • func (f *Frame) Throw(err error)
  • func (f *Frame) Yield(value interface{})
• type FrameMessage
• type Segment

Variables

var AlreadyDoneError = errors.New("already done")

已经执行完成

Types

type Continuation

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

func New

func New(segments ...Segment) *Continuation

创建分段式函数

func (*Continuation) Call

func (c *Continuation) Call(local interface{}) (*Frame, error)

从头开始执行函数

func (*Continuation) CallStep

func (c *Continuation) CallStep(step int, local interface{}) (*Frame, error)

调用指定分段的函数

func (*Continuation) Dump

func (c *Continuation) Dump(frame *Frame) ([]byte, error)

输出当前执行状态数据

func (*Continuation) NewFrame

func (c *Continuation) NewFrame(step int, local interface{}) *Frame

创建新的帧栈

func (*Continuation) Restore

func (c *Continuation) Restore(data []byte) error

恢复执行状态数据并继续执行

func (*Continuation) Resume

func (c *Continuation) Resume(frame *Frame)

继续执行

func (*Continuation) Segment

func (c *Continuation) Segment(segment Segment) *Continuation

增加函数分段

func (*Continuation) Sleep

func (c *Continuation) Sleep(frame *Frame) (result interface{}, err error)

休眠

func (*Continuation) Wait

func (c *Continuation) Wait(frame *Frame) (status FrameMessage, result interface{}, err error)

等待执行结果

type Frame

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

帧栈

func (*Frame) IsDone

func (f *Frame) IsDone() bool

是否已执行完成

func (*Frame) Local

func (f *Frame) Local() interface{}

本地变量

func (*Frame) Next

func (f *Frame) Next(value interface{})

执行下一段

func (*Frame) Return

func (f *Frame) Return(value interface{})

返回结果

func (*Frame) Throw

func (f *Frame) Throw(err error)

抛出异常

func (*Frame) Yield

func (f *Frame) Yield(value interface{})

产生结果，下一步继续执行当前段

type FrameMessage

type FrameMessage int

const (
	FrameStatusSleep FrameMessage = iota
	FrameStatusYield
	FrameStatusNext
	FrameStatusReturn
	FrameStatusThrow
)

type Segment

type Segment func(frame *Frame)

函数段