From 6ad158dd1493eb8bbc2a661fe822726605173f16 Mon Sep 17 00:00:00 2001
From: Juan Batiz-Benet <juan@benet.ai>
Date: Thu, 1 Jan 2015 07:02:16 -0800
Subject: [PATCH] swarm test: reporting errors fix

---
 net/swarm/swarm_test.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/net/swarm/swarm_test.go b/net/swarm/swarm_test.go
index dd89b2443..b532566b8 100644
--- a/net/swarm/swarm_test.go
+++ b/net/swarm/swarm_test.go
@@ -139,7 +139,10 @@ func SubtestSwarm(t *testing.T, SwarmNum int, MsgNum int) {
 				for k := 0; k < MsgNum; k++ { // with k messages
 					msg := "ping"
 					log.Debugf("%s %s %s (%d)", s1.local, msg, p, k)
-					stream.Write([]byte(msg))
+					if _, err := stream.Write([]byte(msg)); err != nil {
+						errChan <- err
+						continue
+					}
 				}
 
 				// read it later
@@ -200,7 +203,7 @@ func SubtestSwarm(t *testing.T, SwarmNum int, MsgNum int) {
 		// check any errors (blocks till consumer is done)
 		for err := range errChan {
 			if err != nil {
-				t.Fatal(err.Error())
+				t.Error(err.Error())
 			}
 		}