@@ -25,10 +25,12 @@
 #endif
 
 @class OFStream;
 @class OFMutableArray;
 @class OFMutableDictionary;
+@class OFDataArray;
+@class OFMutex;
 
 /**
  * \brief A protocol that needs to be implemented by delegates for
  *	  OFStreamObserver.
  */
@@ -78,16 +80,18 @@
 {
 	OFMutableArray *readStreams;
 	OFMutableArray *writeStreams;
 	OFStream **FDToStream;
 	size_t maxFD;
-	OFMutableArray *queue, *queueInfo;
+	OFMutableArray *queue;
+	OFDataArray *queueInfo, *queueFDs;
 	id <OFStreamObserverDelegate> delegate;
 	int cancelFD[2];
 #ifdef _WIN32
 	struct sockaddr_in cancelAddr;
 #endif
+	OFMutex *mutex;
 }
 
 #ifdef OF_HAVE_PROPERTIES
 @property (retain) id <OFStreamObserverDelegate> delegate;
 #endif