@@ -69,10 +69,12 @@
  */
 @interface OFStreamObserver: OFObject
 {
 	OFMutableArray *readStreams;
 	OFMutableArray *writeStreams;
+	OFStream **FDToStream;
+	size_t maxFD;
 	OFMutableArray *queue, *queueInfo;
 	id <OFStreamObserverDelegate> delegate;
 	int cancelFD[2];
 #ifdef _WIN32
 	struct sockaddr_in cancelAddr;
@@ -164,11 +166,12 @@
  * \return A boolean whether events occurred during the timeinterval
  */
 - (BOOL)observeWithTimeout: (int)timeout;
 
 /// \cond internal
+- (void)_processQueue;
 - (BOOL)_processCache;
 /// \endcond
 @end
 
 @interface OFObject (OFStreamObserverDelegate) <OFStreamObserverDelegate>
 @end