testbarrier

Documentation

Overview

Package testbarrier implements a barrier for testing asynchronous systems.

Index

• type Barrier
  • func New() Barrier
  • func (b Barrier) Lift()
  • func (b Barrier) Wait(t testingT, d time.Duration)

Types

type Barrier

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

Barrier blocks tests for a limited duration until an event happens.

func New

func New() Barrier

New creates a Barrier.

func (Barrier) Lift

func (b Barrier) Lift()

Lift the barrier. Must be called when the event happens.

func (Barrier) Wait

func (b Barrier) Wait(t testingT, d time.Duration)

Wait for the barrier to lift for up to a duration `d`. If the deadline expires, the test will fail immediately.