mirror/awesome-patterns
1
0
Fork 0
mirror of https://github.com/crazybber/awesome-patterns.git synced 2024-11-22 12:46:03 +03:00
Code Issues Packages Projects Releases Wiki Activity

[fanout] Remove defect

Browse Source
This commit is contained in:
paulaan 2019-05-02 20:16:56 +07:00
parent 4655d25d08
commit 9c0c9709ff
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
messaging/fanout.go
View File

@ -3,7 +3,6 @@ package messaging
import ( import (
"context" "context"
"go.uber.org/zap" "go.uber.org/zap"
"io"
"sync" "sync"
"sync/atomic" "sync/atomic"
) )
@ -117,9 +116,6 @@ func (c *worker) stream(val interface{}) {
zap.Error(err), zap.Error(err),
) )
} }
if err == io.EOF {
return
}
} }
default: default:
atomic.AddUint32(&idle, 1) atomic.AddUint32(&idle, 1)