xcycle

Documentation

Index

• type Cycle
  • func NewCycle() *Cycle
  • func (c *Cycle) Close()
  • func (c *Cycle) Done() <-chan error
  • func (c *Cycle) DoneAndClose()
  • func (c *Cycle) Run(fn func() error)
  • func (c *Cycle) Wait() <-chan error

Types

type Cycle

type Cycle struct {
	sync.Once
	// contains filtered or unexported fields
}

Cycle ..

func NewCycle

func NewCycle() *Cycle

NewCycle new a cycle life

func (*Cycle) Close

func (c *Cycle) Close()

Close ..

func (*Cycle) Done

func (c *Cycle) Done() <-chan error

Done block and return a chan error

func (*Cycle) DoneAndClose

func (c *Cycle) DoneAndClose()

DoneAndClose ..

func (*Cycle) Run

func (c *Cycle) Run(fn func() error)

Run a new goroutine

func (*Cycle) Wait

func (c *Cycle) Wait() <-chan error

Wait blocked for a life cycle