diff --git a/ReactiveObjC/RACReplaySubject.m b/ReactiveObjC/RACReplaySubject.m index 30475fa9e..ee97ff9e9 100644 --- a/ReactiveObjC/RACReplaySubject.m +++ b/ReactiveObjC/RACReplaySubject.m @@ -85,11 +85,12 @@ - (RACDisposable *)subscribe:(id)subscriber { - (void)sendNext:(id)value { @synchronized (self) { [self.valuesReceived addObject:value ?: RACTupleNil.tupleNil]; - [super sendNext:value]; if (self.capacity != RACReplaySubjectUnlimitedCapacity && self.valuesReceived.count > self.capacity) { [self.valuesReceived removeObjectsInRange:NSMakeRange(0, self.valuesReceived.count - self.capacity)]; } + + [super sendNext:value]; } }