@@ -398,15 +398,15 @@ OF_ENSURE(sendto(_cancelFD[1], "", 1, 0, (struct sockaddr*)&_cancelAddr, sizeof(_cancelAddr)) > 0); #endif } -- (bool)OF_processCache +- (bool)OF_processReadBuffers { id const *objects = [_readObjects objects]; size_t i, count = [_readObjects count]; - bool foundInCache = false; + bool foundInReadBuffer = false; for (i = 0; i < count; i++) { void *pool = objc_autoreleasePoolPush(); if ([objects[i] isKindOfClass: [OFStream class]] && @@ -414,21 +414,21 @@ ![objects[i] OF_isWaitingForDelimiter]) { if ([_delegate respondsToSelector: @selector(objectIsReadyForReading:)]) [_delegate objectIsReadyForReading: objects[i]]; - foundInCache = true; + foundInReadBuffer = true; } objc_autoreleasePoolPop(pool); } /* - * As long as we have data in the cache for any stream, we don't want - * to block. + * As long as we have data in the read buffer for any stream, we don't + * want to block. */ - if (foundInCache) + if (foundInReadBuffer) return true; return false; } @end