From 40fc5bc2ade4cdea08b4c91ecf6d68e845ffeb27 Mon Sep 17 00:00:00 2001 From: Matt Goodall Date: Mon, 22 Apr 2013 10:17:33 +0100 Subject: [PATCH] go fmt --- throughput.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/throughput.go b/throughput.go index b4f4847..9adfe90 100644 --- a/throughput.go +++ b/throughput.go @@ -80,15 +80,15 @@ func consumer(args []string) { count := 0 throughputCount := 0 - go func() { + go func() { throughput := time.Tick(time.Second) total := time.Tick(time.Second * 5) for { select { - case <- throughput: - log.Printf("throughput: %d msgs/s\n", count - throughputCount) + case <-throughput: + log.Printf("throughput: %d msgs/s\n", count-throughputCount) throughputCount = count - case <- total: + case <-total: log.Printf("total: %d\n", count) } } @@ -96,7 +96,7 @@ func consumer(args []string) { for stanza := range x.In { if _, ok := stanza.(*xmpp.Message); ok { - count ++ + count++ } } }