gojay

commit b46c89a4d1d6c43ca3010fecb119c93927cf76a1
parent 21339cc43ebbc9053836a766d3f016e448e8a88a
Author: francoispqt <francois@parquet.ninja>
Date:   Sun, 20 May 2018 01:59:17 +0800

update to use RLock in stream encoding

Diffstat:
M
encode_stream.go
 | 
4
++--

1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/encode_stream.go b/encode_stream.go
@@ -123,14 +123,14 @@ func (s *StreamEncoder) Value(key interface{}) interface{} {
 //
 // After calling cancel, Done() will return a closed channel.
 func (s *StreamEncoder) Cancel(err error) {
-	s.mux.Lock()
+	s.mux.RLock()
 	select {
 	case <-s.done:
 	default:
 		s.err = err
 		close(s.done)
 	}
-	s.mux.Unlock()
+	s.mux.RUnlock()
 }
 
 // AddObject adds an object to be encoded.