diff --git a/AWSIoT/Internal/AWSIoTMQTTClient.m b/AWSIoT/Internal/AWSIoTMQTTClient.m
index 492fbf15fc7..d7b572803ae 100644
--- a/AWSIoT/Internal/AWSIoTMQTTClient.m
+++ b/AWSIoT/Internal/AWSIoTMQTTClient.m
@@ -647,8 +647,8 @@ - (void)cleanupReconnectTimer {
 
 - (void)cleanUpToDecoderStream {
     self.toDecoderStream.delegate = nil;
-    [self.toDecoderStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
     [self.toDecoderStream close];
+    [self.toDecoderStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
     self.toDecoderStream = nil;
 }