From d4039f6319ebf5b91bcbf3128d488dfc6f7be3c3 Mon Sep 17 00:00:00 2001 From: Scott Worley Date: Sat, 28 Jul 2012 12:14:25 -0700 Subject: [PATCH] Test multiple listeners --- server/server_test.go | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) 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) +} -- 2.44.1