Ignoring stream messages for closed streams

Author: schmidt-sebastian

Firestore/Source/Remote/FSTStream.m

@@ -516,7 +516,7 @@ - (void)handleStreamMessage:(id)value {
 - (void)handleStreamClose:(nullable NSError *)error {
   FSTLog(@"%@ %p close: %@", NSStringFromClass([self class]), (__bridge void *)self, error);
 
-  if (![self isStarted]) {   // The stream could have already been closed by the idle close timer.
+  if (![self isStarted]) {  // The stream could have already been closed by the idle close timer.
     FSTLog(@"%@ Ignoring server close for already closed stream.", NSStringFromClass([self class]));
     return;
   }
@@ -542,9 +542,10 @@ - (void)writeValue:(id)value __used {
   FSTWeakify(self);
   [self.workerDispatchQueue dispatchAsync:^{
     FSTStrongify(self);
-    if (!self || self.state == FSTStreamStateStopped) {
-      return;
+    if (!self || ![self isStarted]) {
+      FSTLog(@"%@ Ignoring stream message from inactive stream.", NSStringFromClass([self class]));
     }
+
     if (!self.messageReceived) {
       self.messageReceived = YES;
       if ([FIRFirestore isLoggingEnabled]) {