From 2d545c87cd617edf68e0596201845d372b36b13c Mon Sep 17 00:00:00 2001
From: Mathias Fredriksson <mafredri@gmail.com>
Date: Sat, 23 Jan 2021 22:22:25 +0200
Subject: [PATCH] rpc: fix read mutex unlock in dataconn stream

closes #413
---
 rpc/dataconn/stream/stream_conn.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/rpc/dataconn/stream/stream_conn.go b/rpc/dataconn/stream/stream_conn.go
index 1ab05b0..bcbed6e 100644
--- a/rpc/dataconn/stream/stream_conn.go
+++ b/rpc/dataconn/stream/stream_conn.go
@@ -144,6 +144,7 @@ func (c *Conn) ReadStream(frameType uint32, closeConnOnClose bool) (_ *StreamRea
 
 	c.readMtx.Lock()
 	if !c.readClean {
+		c.readMtx.Unlock()
 		return nil, errWriteStreamToErrorUnknownState
 	}