From: Scott Worley Date: Sat, 28 Jul 2012 19:14:25 +0000 (-0700) Subject: Test multiple listeners X-Git-Url: http://git.scottworley.com/reliable-chat/commitdiff_plain/d4039f6319ebf5b91bcbf3128d488dfc6f7be3c3?ds=sidebyside;hp=--cc Test multiple listeners --- d4039f6319ebf5b91bcbf3128d488dfc6f7be3c3 diff --git a/server/server_test.go b/server/server_test.go index 516f62a..fd4a4c8 100644 --- a/server/server_test.go +++ b/server/server_test.go @@ -51,3 +51,31 @@ func TestFetchBlocksUntilSpeak(t *testing.T) { close(store.Get) close(store.Add) } + +func TestMultipleListeners(t *testing.T) { + say := "This is your nine o'clock alarm call!" + at := time.Now() + var zero_time time.Time + store := start_store() + const num_clients = 13 + var messages_from_store [num_clients]chan []Message + for i := 0; i < num_clients; i++ { + messages_from_store[i] = make(chan []Message, 1) + store.Get <- &StoreRequest{zero_time, messages_from_store[i]} + } + store.Add <- &Message{at, say} + for i := 0; i < num_clients; i++ { + messages := <-messages_from_store[i] + if len(messages) != 1 { + t.Fail() + } + if messages[0].Time != at { + t.Fail() + } + if messages[0].Text != say { + t.Fail() + } + } + close(store.Get) + close(store.Add) +}