diff --git a/stream.go b/stream.go
index b3adde9..12a370a 100644
--- a/stream.go
+++ b/stream.go
@@ -40,8 +40,6 @@ type Stream struct {
 	recvLock sync.Mutex
 	recvBuf  segmentedBuffer
 
-	sendLock sync.Mutex
-
 	recvNotifyCh chan struct{}
 	sendNotifyCh chan struct{}
 
@@ -123,11 +121,8 @@ WAIT:
 }
 
 // Write is used to write to the stream
-func (s *Stream) Write(b []byte) (n int, err error) {
-	s.sendLock.Lock()
-	defer s.sendLock.Unlock()
-	total := 0
-
+func (s *Stream) Write(b []byte) (int, error) {
+	var total int
 	for total < len(b) {
 		n, err := s.write(b[total:])
 		total += n