diff options
Diffstat (limited to 'core')
| -rw-r--r-- | core/channel.go | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/core/channel.go b/core/channel.go index 6cb02f7..2e73917 100644 --- a/core/channel.go +++ b/core/channel.go @@ -184,10 +184,7 @@ func (ch *Channel) SetReplyTimeout(timeout time.Duration) { } func (ch *Channel) Close() { - if ch.reqChan != nil { - close(ch.reqChan) - ch.reqChan = nil - } + close(ch.reqChan) } func (req *requestCtx) ReceiveReply(msg api.Message) error { |