@@ -63,11 +63,11 @@ + (instancetype)socket { return [[[self alloc] init] autorelease]; } -- (BOOL)lowlevelIsAtEndOfStream +- (bool)lowlevelIsAtEndOfStream { return _atEndOfStream; } - (size_t)lowlevelReadIntoBuffer: (void*)buffer @@ -98,11 +98,11 @@ @throw [OFReadFailedException exceptionWithClass: [self class] stream: self requestedLength: length]; if (ret == 0) - _atEndOfStream = YES; + _atEndOfStream = true; return ret; } - (void)lowlevelWriteBuffer: (const void*)buffer @@ -132,11 +132,11 @@ stream: self requestedLength: length]; } #ifdef _WIN32 -- (void)setBlocking: (BOOL)enable +- (void)setBlocking: (bool)enable { u_long v = enable; _blocking = enable; if (ioctlsocket(_socket, FIONBIO, &v) == SOCKET_ERROR) @@ -163,11 +163,11 @@ socket: self]; close(_socket); _socket = INVALID_SOCKET; - _atEndOfStream = NO; + _atEndOfStream = false; } - (void)dealloc { if (_socket != INVALID_SOCKET)