@@ -26,12 +26,10 @@
 # include <poll.h>
 #endif
 
 #import "OFPollKernelEventObserver.h"
 #import "OFData.h"
-#import "OFKernelEventObserver+Private.h"
-#import "OFKernelEventObserver.h"
 
 #import "OFObserveFailedException.h"
 #import "OFOutOfRangeException.h"
 
 #import "socket_helpers.h"
@@ -124,32 +122,32 @@
 			break;
 		}
 	}
 }
 
-- (void)of_addObjectForReading: (id <OFReadyForReadingObserving>)object
+- (void)addObjectForReading: (id <OFReadyForReadingObserving>)object
 {
 	[self of_addObject: object
 	    fileDescriptor: object.fileDescriptorForReading
 		    events: POLLIN];
 }
 
-- (void)of_addObjectForWriting: (id <OFReadyForWritingObserving>)object
+- (void)addObjectForWriting: (id <OFReadyForWritingObserving>)object
 {
 	[self of_addObject: object
 	    fileDescriptor: object.fileDescriptorForWriting
 		    events: POLLOUT];
 }
 
-- (void)of_removeObjectForReading: (id <OFReadyForReadingObserving>)object
+- (void)removeObjectForReading: (id <OFReadyForReadingObserving>)object
 {
 	[self of_removeObject: object
 	       fileDescriptor: object.fileDescriptorForReading
 		       events: POLLIN];
 }
 
-- (void)of_removeObjectForWriting: (id <OFReadyForWritingObserving>)object
+- (void)removeObjectForWriting: (id <OFReadyForWritingObserving>)object
 {
 	[self of_removeObject: object
 	       fileDescriptor: object.fileDescriptorForWriting
 		       events: POLLOUT];
 }
@@ -158,12 +156,10 @@
 {
 	struct pollfd *FDs;
 	int events;
 	size_t nFDs;
 
-	[self of_processQueue];
-
 	if ([self of_processReadBuffers])
 		return;
 
 	FDs = _FDs.mutableItems;
 	nFDs = _FDs.count;