kubernetes/staging/src/k8s.io/apimachinery/pkg/watch/mux_test.go

type myType …

func (obj *myType) GetObjectKind() schema.ObjectKind { … }

func (obj *myType) DeepCopyObject() runtime.Object { … }

func TestBroadcaster(t *testing.T) { … }

func TestBroadcasterWatcherClose(t *testing.T) { … }

func TestBroadcasterWatcherStopDeadlock(t *testing.T) { … }

func TestBroadcasterDropIfChannelFull(t *testing.T) { … }

func BenchmarkBroadCaster(b *testing.B) { … }

func TestBroadcasterWatchAfterShutdown(t *testing.T) { … }

func TestBroadcasterSendEventAfterShutdown(t *testing.T) { … }

// Test this since we see usage patterns where the broadcaster and watchers are
// stopped simultaneously leading to races.
func TestBroadcasterShutdownRace(t *testing.T) { … }