Documentation
¶
Index ¶
- func ShouldBlock(actual interface{}, expected ...interface{}) string
- func ShouldNotBlock(actual interface{}, expected ...interface{}) string
- type ObserverGroup
- func (g *ObserverGroup) AddObserver() chan struct{}
- func (g *ObserverGroup) AddObserverWithTimeout(duration time.Duration) chan struct{}
- func (g *ObserverGroup) AttachObserver(observer chan struct{})
- func (g *ObserverGroup) DetachObserver(observer chan struct{}) bool
- func (g *ObserverGroup) Notify()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ShouldBlock ¶
func ShouldBlock(actual interface{}, expected ...interface{}) string
func ShouldNotBlock ¶
func ShouldNotBlock(actual interface{}, expected ...interface{}) string
Types ¶
type ObserverGroup ¶
type ObserverGroup struct {
// contains filtered or unexported fields
}
func NewObserverGroup ¶
func NewObserverGroup(logger logging.Logger) *ObserverGroup
func (*ObserverGroup) AddObserver ¶
func (g *ObserverGroup) AddObserver() chan struct{}
func (*ObserverGroup) AddObserverWithTimeout ¶
func (g *ObserverGroup) AddObserverWithTimeout(duration time.Duration) chan struct{}
func (*ObserverGroup) AttachObserver ¶
func (g *ObserverGroup) AttachObserver(observer chan struct{})
func (*ObserverGroup) DetachObserver ¶
func (g *ObserverGroup) DetachObserver(observer chan struct{}) bool
func (*ObserverGroup) Notify ¶
func (g *ObserverGroup) Notify()
Source Files
Click to show internal directories.
Click to hide internal directories.