@@ -73,12 +73,12 @@ - (void)of_addObject: (id)object fileDescriptor: (int)fd events: (short)events { - struct pollfd *FDs = [_FDs items]; - size_t count = [_FDs count]; + struct pollfd *FDs = _FDs.mutableItems; + size_t count = _FDs.count; bool found = false; for (size_t i = 0; i < count; i++) { if (FDs[i].fd == fd) { FDs[i].events |= events; @@ -104,12 +104,12 @@ - (void)of_removeObject: (id)object fileDescriptor: (int)fd events: (short)events { - struct pollfd *FDs = [_FDs items]; - size_t nFDs = [_FDs count]; + struct pollfd *FDs = _FDs.mutableItems; + size_t nFDs = _FDs.count; for (size_t i = 0; i < nFDs; i++) { if (FDs[i].fd == fd) { FDs[i].events &= ~events; @@ -127,32 +127,32 @@ } - (void)of_addObjectForReading: (id )object { [self of_addObject: object - fileDescriptor: [object fileDescriptorForReading] + fileDescriptor: object.fileDescriptorForReading events: POLLIN]; } - (void)of_addObjectForWriting: (id )object { [self of_addObject: object - fileDescriptor: [object fileDescriptorForWriting] + fileDescriptor: object.fileDescriptorForWriting events: POLLOUT]; } - (void)of_removeObjectForReading: (id )object { [self of_removeObject: object - fileDescriptor: [object fileDescriptorForReading] + fileDescriptor: object.fileDescriptorForReading events: POLLIN]; } - (void)of_removeObjectForWriting: (id )object { [self of_removeObject: object - fileDescriptor: [object fileDescriptorForWriting] + fileDescriptor: object.fileDescriptorForWriting events: POLLOUT]; } - (void)observeForTimeInterval: (of_time_interval_t)timeInterval { @@ -163,12 +163,12 @@ [self of_processQueue]; if ([self of_processReadBuffers]) return; - FDs = [_FDs items]; - nFDs = [_FDs count]; + FDs = _FDs.mutableItems; + nFDs = _FDs.count; #ifdef OPEN_MAX if (nFDs > OPEN_MAX) @throw [OFOutOfRangeException exception]; #endif