@@ -405,23 +405,23 @@ id const *objects = [_readObjects objects]; size_t i, count = [_readObjects count]; bool foundInCache = false; for (i = 0; i < count; i++) { + void *pool = objc_autoreleasePoolPush(); + if ([objects[i] isKindOfClass: [OFStream class]] && [objects[i] hasDataInReadBuffer] && ![objects[i] OF_isWaitingForDelimiter]) { - void *pool = objc_autoreleasePoolPush(); - if ([_delegate respondsToSelector: @selector(objectIsReadyForReading:)]) [_delegate objectIsReadyForReading: objects[i]]; foundInCache = true; + } - objc_autoreleasePoolPop(pool); - } + objc_autoreleasePoolPop(pool); } /* * As long as we have data in the cache for any stream, we don't want * to block.