@@ -187,11 +187,11 @@
 - (void)addStreamForReading: (OFStream*)stream
 {
 	[mutex lock];
 	@try {
 		int qi = QUEUE_ADD | QUEUE_READ;
-		int fd = [stream fileDescriptor];
+		int fd = [stream fileDescriptorForReading];
 
 		[queue addObject: stream];
 		[queueInfo addItem: &qi];
 		[queueFDs addItem: &fd];
 	} @finally {
@@ -204,11 +204,11 @@
 - (void)addStreamForWriting: (OFStream*)stream
 {
 	[mutex lock];
 	@try {
 		int qi = QUEUE_ADD | QUEUE_WRITE;
-		int fd = [stream fileDescriptor];
+		int fd = [stream fileDescriptorForWriting];
 
 		[queue addObject: stream];
 		[queueInfo addItem: &qi];
 		[queueFDs addItem: &fd];
 	} @finally {
@@ -221,11 +221,11 @@
 - (void)removeStreamForReading: (OFStream*)stream
 {
 	[mutex lock];
 	@try {
 		int qi = QUEUE_REMOVE | QUEUE_READ;
-		int fd = [stream fileDescriptor];
+		int fd = [stream fileDescriptorForReading];
 
 		[queue addObject: stream];
 		[queueInfo addItem: &qi];
 		[queueFDs addItem: &fd];
 	} @finally {
@@ -243,11 +243,11 @@
 - (void)removeStreamForWriting: (OFStream*)stream
 {
 	[mutex lock];
 	@try {
 		int qi = QUEUE_REMOVE | QUEUE_WRITE;
-		int fd = [stream fileDescriptor];
+		int fd = [stream fileDescriptorForWriting];
 
 		[queue addObject: stream];
 		[queueInfo addItem: &qi];
 		[queueFDs addItem: &fd];
 	} @finally {