@@ -218,11 +218,11 @@
 	@synchronized (queue) {
 		[queue addObject: stream];
 		[queueInfo addObject: qi];
 	}
 
-	write(cancelFd[1], "", 1);
+	assert(!write(cancelFd[1], "", 1));
 
 	[pool release];
 }
 
 - (void)addStreamToObserveForWriting: (OFStream*)stream
@@ -233,11 +233,11 @@
 	@synchronized (queue) {
 		[queue addObject: stream];
 		[queueInfo addObject: qi];
 	}
 
-	write(cancelFd[1], "", 1);
+	assert(!write(cancelFd[1], "", 1));
 
 	[pool release];
 }
 
 - (void)removeStreamToObserveForReading: (OFStream*)stream
@@ -248,11 +248,11 @@
 	@synchronized (queue) {
 		[queue addObject: stream];
 		[queueInfo addObject: qi];
 	}
 
-	write(cancelFd[1], "", 1);
+	assert(!write(cancelFd[1], "", 1));
 
 	[pool release];
 }
 
 - (void)removeStreamToObserveForWriting: (OFStream*)stream
@@ -263,11 +263,11 @@
 	@synchronized (queue) {
 		[queue addObject: stream];
 		[queueInfo addObject: qi];
 	}
 
-	write(cancelFd[1], "", 1);
+	assert(!write(cancelFd[1], "", 1));
 
 	[pool release];
 }
 
 - (void)_processQueue
@@ -392,11 +392,11 @@
 
 		if (fds_c[i].revents & POLLIN) {
 			if (fds_c[i].fd == cancelFd[0]) {
 				char buf;
 
-				read(cancelFd[0], &buf, 1);
+				assert(!read(cancelFd[0], &buf, 1));
 				fds_c[i].revents = 0;
 
 				continue;
 			}
 
@@ -437,11 +437,11 @@
 	    (timeout != -1 ? &tv : NULL)) < 1)
 		return NO;
 
 	if (FD_ISSET(cancelFd[0], &readfds_)) {
 		char buf;
-		read(cancelFd[0], &buf, 1);
+		assert(!read(cancelFd[0], &buf, 1));
 	}
 
 	for (i = 0; i < count; i++) {
 		int fd = [cArray[i] fileDescriptor];