concurrent

Documentation

Index

• func Async(exec func())
• type Assertion
  • func NewAssertion(expected int) *Assertion
  • func (a *Assertion) Assert(t *testing.T)
  • func (a *Assertion) Expect(v interface{})
• type Counter
  • func NewCounter(waitGroup *sync.WaitGroup) *Counter
  • func (c *Counter) Get() int
  • func (c *Counter) Track(v interface{})
  • func (c *Counter) Values() []interface{}

Functions

func Async

func Async(exec func())

Types

type Assertion

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

func NewAssertion

func NewAssertion(expected int) *Assertion

func (*Assertion) Assert

func (a *Assertion) Assert(t *testing.T)

func (*Assertion) Expect

func (a *Assertion) Expect(v interface{})

type Counter

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

Counter is a synchronous counter for tracking events and synchronising progress.

func NewCounter

func NewCounter(waitGroup *sync.WaitGroup) *Counter

NewCounter creates a new counter.

func (*Counter) Get

func (c *Counter) Get() int

Get returns the current count.

func (*Counter) Track

func (c *Counter) Track(v interface{})

Track increments the counter by one and potentially adds the object to it's memory.

func (*Counter) Values

func (c *Counter) Values() []interface{}

Values returns the tracked values.