Index: src/OFKernelEventObserver.m
==================================================================
--- src/OFKernelEventObserver.m
+++ src/OFKernelEventObserver.m
@@ -212,14 +212,15 @@
 	[_writeObjects removeObjectIdenticalTo: object];
 }
 
 - (bool)of_processReadBuffers
 {
+	void *pool = objc_autoreleasePoolPush();
 	bool foundInReadBuffer = false;
 
-	for (id object in _readObjects) {
-		void *pool = objc_autoreleasePoolPush();
+	for (id object in [[_readObjects copy] autorelease]) {
+		void *pool2 = objc_autoreleasePoolPush();
 
 		if ([object isKindOfClass: [OFStream class]] &&
 		    [object hasDataInReadBuffer] &&
 		    ![(OFStream *)object of_isWaitingForDelimiter]) {
 			if ([_delegate respondsToSelector:
@@ -227,12 +228,14 @@
 				[_delegate objectIsReadyForReading: object];
 
 			foundInReadBuffer = true;
 		}
 
-		objc_autoreleasePoolPop(pool);
+		objc_autoreleasePoolPop(pool2);
 	}
+
+	objc_autoreleasePoolPop(pool);
 
 	/*
 	 * As long as we have data in the read buffer for any stream, we don't
 	 * want to block.
 	 */

Index: src/OFSelectKernelEventObserver.m
==================================================================
--- src/OFSelectKernelEventObserver.m
+++ src/OFSelectKernelEventObserver.m
@@ -165,19 +165,18 @@
 	[super removeObjectForWriting: object];
 }
 
 - (void)observeForTimeInterval: (of_time_interval_t)timeInterval
 {
-	id const *objects;
 	fd_set readFDs;
 	fd_set writeFDs;
 	struct timeval timeout;
 	int events;
 #ifdef OF_AMIGAOS
 	ULONG execSignalMask, cancelSignal;
 #endif
-	size_t count;
+	void *pool;
 
 	if ([self of_processReadBuffers])
 		return;
 
 #ifdef FD_COPY
@@ -247,36 +246,36 @@
 		    NULL) == 1);
 # endif
 	}
 #endif
 
-	objects = _readObjects.objects;
-	count = _readObjects.count;
+	pool = objc_autoreleasePoolPush();
 
-	for (size_t i = 0; i < count; i++) {
-		void *pool = objc_autoreleasePoolPush();
-		int fd = [objects[i] fileDescriptorForReading];
+	for (id <OFReadyForReadingObserving> object in
+	    [[_readObjects copy] autorelease]) {
+		void *pool2 = objc_autoreleasePoolPush();
+		int fd = object.fileDescriptorForReading;
 
 		if (FD_ISSET((of_socket_t)fd, &readFDs) &&
 		    [_delegate respondsToSelector:
 		    @selector(objectIsReadyForReading:)])
-			[_delegate objectIsReadyForReading: objects[i]];
+			[_delegate objectIsReadyForReading: object];
 
-		objc_autoreleasePoolPop(pool);
+		objc_autoreleasePoolPop(pool2);
 	}
 
-	objects = _writeObjects.objects;
-	count = _writeObjects.count;
-
-	for (size_t i = 0; i < count; i++) {
-		void *pool = objc_autoreleasePoolPush();
-		int fd = [objects[i] fileDescriptorForWriting];
+	for (id <OFReadyForWritingObserving> object in
+	    [[_writeObjects copy] autorelease]) {
+		void *pool2 = objc_autoreleasePoolPush();
+		int fd = object.fileDescriptorForWriting;
 
 		if (FD_ISSET((of_socket_t)fd, &writeFDs) &&
 		    [_delegate respondsToSelector:
 		    @selector(objectIsReadyForWriting:)])
-			[_delegate objectIsReadyForWriting: objects[i]];
+			[_delegate objectIsReadyForWriting: object];
 
-		objc_autoreleasePoolPop(pool);
+		objc_autoreleasePoolPop(pool2);
 	}
+
+	objc_autoreleasePoolPop(pool);
 }
 @end