@@ -57,11 +57,11 @@
 	QUEUE_WRITE = 2
 };
 #define QUEUE_ACTION (QUEUE_ADD | QUEUE_REMOVE)
 
 @implementation OFStreamObserver
-+ observer
++ (instancetype)observer
 {
 	return [[[self alloc] init] autorelease];
 }
 
 #if defined(HAVE_KQUEUE)