@@ -193,11 +193,14 @@
 		     length: (size_t)length
 		     target: (id)target
 		   selector: (SEL)selector
 		    context: (id)context
 {
-	[OFRunLoop of_addAsyncReadForStream: self
+	OFStream <OFReadyForReadingObserving> *stream =
+	    (OFStream <OFReadyForReadingObserving> *)self;
+
+	[OFRunLoop of_addAsyncReadForStream: stream
 				     buffer: buffer
 				     length: length
 				     target: target
 				   selector: selector
 				    context: context];
@@ -207,11 +210,14 @@
 		exactLength: (size_t)length
 		     target: (id)target
 		   selector: (SEL)selector
 		    context: (id)context
 {
-	[OFRunLoop of_addAsyncReadForStream: self
+	OFStream <OFReadyForReadingObserving> *stream =
+	    (OFStream <OFReadyForReadingObserving> *)self;
+
+	[OFRunLoop of_addAsyncReadForStream: stream
 				     buffer: buffer
 				exactLength: length
 				     target: target
 				   selector: selector
 				    context: context];
@@ -220,21 +226,27 @@
 # ifdef OF_HAVE_BLOCKS
 - (void)asyncReadIntoBuffer: (void *)buffer
 		     length: (size_t)length
 		      block: (of_stream_async_read_block_t)block
 {
-	[OFRunLoop of_addAsyncReadForStream: self
+	OFStream <OFReadyForReadingObserving> *stream =
+	    (OFStream <OFReadyForReadingObserving> *)self;
+
+	[OFRunLoop of_addAsyncReadForStream: stream
 				     buffer: buffer
 				     length: length
 				      block: block];
 }
 
 - (void)asyncReadIntoBuffer: (void *)buffer
 		exactLength: (size_t)length
 		      block: (of_stream_async_read_block_t)block
 {
-	[OFRunLoop of_addAsyncReadForStream: self
+	OFStream <OFReadyForReadingObserving> *stream =
+	    (OFStream <OFReadyForReadingObserving> *)self;
+
+	[OFRunLoop of_addAsyncReadForStream: stream
 				     buffer: buffer
 				exactLength: length
 				      block: block];
 }
 # endif
@@ -828,11 +840,14 @@
 - (void)asyncReadLineWithEncoding: (of_string_encoding_t)encoding
 			   target: (id)target
 			 selector: (SEL)selector
 			  context: (id)context
 {
-	[OFRunLoop of_addAsyncReadLineForStream: self
+	OFStream <OFReadyForReadingObserving> *stream =
+	    (OFStream <OFReadyForReadingObserving> *)self;
+
+	[OFRunLoop of_addAsyncReadLineForStream: stream
 				       encoding: encoding
 					 target: target
 				       selector: selector
 					context: context];
 }
@@ -845,11 +860,14 @@
 }
 
 - (void)asyncReadLineWithEncoding: (of_string_encoding_t)encoding
 			    block: (of_stream_async_read_line_block_t)block
 {
-	[OFRunLoop of_addAsyncReadLineForStream: self
+	OFStream <OFReadyForReadingObserving> *stream =
+	    (OFStream <OFReadyForReadingObserving> *)self;
+
+	[OFRunLoop of_addAsyncReadLineForStream: stream
 				       encoding: encoding
 					  block: block];
 }
 # endif
 #endif
@@ -1077,11 +1095,14 @@
 		  length: (size_t)length
 		  target: (id)target
 		selector: (SEL)selector
 		 context: (id)context
 {
-	[OFRunLoop of_addAsyncWriteForStream: self
+	OFStream <OFReadyForWritingObserving> *stream =
+	    (OFStream <OFReadyForWritingObserving> *)self;
+
+	[OFRunLoop of_addAsyncWriteForStream: stream
 				      buffer: buffer
 				      length: length
 				      target: target
 				    selector: selector
 				     context: context];
@@ -1090,11 +1111,14 @@
 # ifdef OF_HAVE_BLOCKS
 - (void)asyncWriteBuffer: (const void *)buffer
 		  length: (size_t)length
 		   block: (of_stream_async_write_block_t)block
 {
-	[OFRunLoop of_addAsyncWriteForStream: self
+	OFStream <OFReadyForWritingObserving> *stream =
+	    (OFStream <OFReadyForWritingObserving> *)self;
+
+	[OFRunLoop of_addAsyncWriteForStream: stream
 				      buffer: buffer
 				      length: length
 				       block: block];
 }
 # endif