fix(bitswap) shut down async

23802fdf · Brian Tiger Chow · d42ec402 · 23802fdf
Commit 23802fdf authored Nov 05, 2014 by Brian Tiger Chow
Show whitespace changes
Inline Side-by-side

Showing with 3 additions and 5 deletions

bitswap.go bitswap.go +3 -5

No files found.
--- a/bitswap.go
+++ b/bitswap.go
@@ -32,12 +32,10 @@ func NetMessageSession(ctx context.Context, p peer.Peer,
 	notif := notifications.New()

 	go func() {
-		for {
 		select {
 		case <-ctx.Done():
 			notif.Shutdown()
 		}
-		}
 	}()

 	bs := &bitswap{