From 9c0c9709ff557163ed67bb5dec765463ee737d3c Mon Sep 17 00:00:00 2001 From: paulaan Date: Thu, 2 May 2019 20:16:56 +0700 Subject: [PATCH] [fanout] Remove defect --- messaging/fanout.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/messaging/fanout.go b/messaging/fanout.go index 83cf36e..6bbd2be 100644 --- a/messaging/fanout.go +++ b/messaging/fanout.go @@ -3,7 +3,6 @@ package messaging import ( "context" "go.uber.org/zap" - "io" "sync" "sync/atomic" ) @@ -117,9 +116,6 @@ func (c *worker) stream(val interface{}) { zap.Error(err), ) } - if err == io.EOF { - return - } } default: atomic.AddUint32(&idle, 1)