diff options
| author |  Sebastian Schmidt <mrschmidt@google.com> | 2017-12-01 12:30:52 -0800 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2017-12-01 12:30:52 -0800 |
| commit | 4da1d25ac51ca7236227987b7320fd3cd0f17ab1 (patch) | |
| tree | b59f9da3b4c92ccc4d97402c98f7057cffe6bf56 /Firestore | |
| parent | 7c7da198eeda7392803e812b0062eb3e9119cade (diff) | |
| parent | 7db1fc5beead336b19f47a56eb4dcc39ec8f4216 (diff) | |
Merge pull request #522 from firebase/mrschmidt-crash
Ignoring stream messages for closed streams
Diffstat (limited to 'Firestore')
| -rw-r--r-- | Firestore/Source/Remote/FSTStream.m | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/Firestore/Source/Remote/FSTStream.m b/Firestore/Source/Remote/FSTStream.m index ac51cb9..21b343a 100644 --- a/Firestore/Source/Remote/FSTStream.m +++ b/Firestore/Source/Remote/FSTStream.m @@ -542,9 +542,10 @@ static const NSTimeInterval kIdleTimeout = 60.0; 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]) { |