fixup race on ch.reqChan

[govpp.git] / core / channel.go

diff --git a/core/channel.go b/core/channel.go
index 6cb02f7..2e73917 100644 (file)
--- 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 {