fix(stream): set writeDeadline when cleanup and forceClose

fixes libp2p#11
terryding77 · Jan 19, 2020 · 48208ae · 48208ae
1 parent 736c1cb
commit 48208ae
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/stream.go b/stream.go
@@ -321,14 +321,14 @@ func (s *Stream) forceClose() {
 	s.notifyWaiting()
 
 	s.readDeadline.set(time.Time{})
-	s.readDeadline.set(time.Time{})
+	s.writeDeadline.set(time.Time{})
 }
 
 // called when fully closed to release any system resources.
 func (s *Stream) cleanup() {
 	s.session.closeStream(s.id)
 	s.readDeadline.set(time.Time{})
-	s.readDeadline.set(time.Time{})
+	s.writeDeadline.set(time.Time{})
 }
 
 // processFlags is used to update the state of the stream