Fix more leaks

This commit is contained in:
Isaac 2025-03-04 16:18:44 +01:00
parent 11bf1f13d0
commit 0d4a8403fc

View File

@ -230,10 +230,10 @@
terminated = _terminated; terminated = _terminated;
os_unfair_lock_unlock(&_lock); os_unfair_lock_unlock(&_lock);
if (terminated) if (terminated) {
[_subscriber putCompletion]; [_subscriber putCompletion];
else if (nextSignal != nil) _subscriber = nil;
{ } else if (nextSignal != nil) {
__weak MTSignalQueueState *weakSelf = self; __weak MTSignalQueueState *weakSelf = self;
id<MTDisposable> disposable = [nextSignal startWithNext:^(id next) id<MTDisposable> disposable = [nextSignal startWithNext:^(id next)
{ {
@ -282,6 +282,7 @@
{ {
[_currentDisposable dispose]; [_currentDisposable dispose];
[_disposable dispose]; [_disposable dispose];
_subscriber = nil;
} }
@end @end