Function TestStoreWatchSlowConsumer

tests/integration/v2store/store_test.go:824–836

TestStoreWatchSlowConsumer ensures that slow consumers are handled properly. Since Watcher.EventChan() has a buffer of size 100 we can only queue 100 event per watcher. If the consumer cannot consume the event on time and another event arrives, the channel is closed and event is discarded. This tes

(t *testing.T)

// This test ensures that after closing the channel, the store can continue
// to operate correctly.
func TestStoreWatchSlowConsumer(t *testing.T) {
	s := v2store.New()
	s.Watch("/foo", true, true, 0) // stream must be true
	// Fill watch channel with 100 events
	for i := 1; i <= 100; i++ {
		s.Set("/foo", false, fmt.Sprint(i), v2store.TTLOptionSet{ExpireTime: v2store.Permanent}) // ok
	}
	// assert.Equal(t, s.WatcherHub.count, int64(1))
	s.Set("/foo", false, "101", v2store.TTLOptionSet{ExpireTime: v2store.Permanent}) // ok
	// remove watcher
	// assert.Equal(t, s.WatcherHub.count, int64(0))
	s.Set("/foo", false, "102", v2store.TTLOptionSet{ExpireTime: v2store.Permanent}) // must not panic
}

// Performs a non-blocking select on an event channel.
func nbselect(c <-chan *v2store.Event) *v2store.Event {