diff --git a/stream.go b/stream.go
index 5cb9399..62ccb04 100644
--- 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