@@ -113,11 +113,11 @@
 #endif
 
 		_readObjects = [[OFMutableArray alloc] init];
 		_writeObjects = [[OFMutableArray alloc] init];
 
-#if defined(OF_HAVE_PIPE)
+#if defined(OF_HAVE_PIPE) && !defined(OF_AMIGAOS)
 		if (pipe(_cancelFD))
 			@throw [OFInitializationFailedException
 			    exceptionWithClass: self.class];
 #elif !defined(OF_AMIGAOS)
 		_cancelFD[0] = _cancelFD[1] = socket(AF_INET, SOCK_DGRAM, 0);
@@ -174,11 +174,11 @@
 	return self;
 }
 
 - (void)dealloc
 {
-#if defined(OF_HAVE_PIPE)
+#if defined(OF_HAVE_PIPE) && !defined(OF_AMIGAOS)
 	close(_cancelFD[0]);
 	if (_cancelFD[1] != _cancelFD[0])
 		close(_cancelFD[1]);
 #elif !defined(OF_AMIGAOS)
 	closesocket(_cancelFD[0]);
@@ -257,25 +257,25 @@
 	[self observeForTimeInterval: date.timeIntervalSinceNow];
 }
 
 - (void)cancel
 {
-#if defined(OF_HAVE_PIPE)
-	OF_ENSURE(write(_cancelFD[1], "", 1) > 0);
-#elif defined(OF_AMIGAOS)
+#if defined(OF_AMIGAOS)
 	Forbid();
 
 	if (_waitingTask != NULL) {
 		Signal(_waitingTask, (1ul << _cancelSignal));
 		_waitingTask = NULL;
 	}
 
 	Permit();
+#elif defined(OF_HAVE_PIPE)
+	OF_ENSURE(write(_cancelFD[1], "", 1) > 0);
 #elif defined(OF_WII)
 	OF_ENSURE(sendto(_cancelFD[1], "", 1, 0,
 	    (struct sockaddr *)&_cancelAddr, 8) > 0);
 #else
 	OF_ENSURE(sendto(_cancelFD[1], (void *)"", 1, 0,
 	    (struct sockaddr *)&_cancelAddr, sizeof(_cancelAddr)) > 0);
 #endif
 }
 @end