Merge pull request #876 from ijt/patch-1

use more idiomatic for loop in ExamplePubSub

example_test.go

@@ -343,11 +343,7 @@ func ExamplePubSub() {
 	})
 
 	// Consume messages.
-	for {
-		msg, ok := <-ch
-		if !ok {
-			break
-		}
+	for msg := range ch {
 		fmt.Println(msg.Channel, msg.Payload)
 	}