diff --git a/peer.go b/peer.go
index 25a1f30d..d83f7c37 100644
--- a/peer.go
+++ b/peer.go
@@ -473,6 +473,7 @@ func (c *chanMsgStream) msgConsumer() {
 			case <-c.quit:
 				peerLog.Tracef("Update stream for "+
 					"ChannelID(%x) exiting", c.cid[:])
+				c.msgCond.L.Unlock()
 				return
 			default:
 			}