@@ -85,12 +85,12 @@
 		_atEndOfStream = true;
 
 	return ret;
 }
 
-- (void)lowlevelWriteBuffer: (const void *)buffer
-		     length: (size_t)length
+- (size_t)lowlevelWriteBuffer: (const void *)buffer
+		       length: (size_t)length
 {
 	if (_socket == INVALID_SOCKET)
 		@throw [OFNotOpenException exceptionWithObject: self];
 
 #ifndef OF_WINDOWS
@@ -117,15 +117,11 @@
 			requestedLength: length
 			   bytesWritten: 0
 				  errNo: of_socket_errno()];
 #endif
 
-	if ((size_t)bytesWritten != length)
-		@throw [OFWriteFailedException exceptionWithObject: self
-						   requestedLength: length
-						      bytesWritten: bytesWritten
-							     errNo: 0];
+	return (size_t)bytesWritten;
 }
 
 #ifdef OF_WINDOWS
 - (void)setBlocking: (bool)enable
 {