diff --git a/StreamingKit/StreamingKit/STKHttpDataSource.m b/StreamingKit/StreamingKit/STKHttpDataSource.m
index ae24460..f01126a 100644
--- a/StreamingKit/StreamingKit/STKHttpDataSource.m
+++ b/StreamingKit/StreamingKit/STKHttpDataSource.m
@@ -220,7 +220,7 @@
 {
     self->currentUrl = urlProvider();
     
-    CFHTTPMessageRef message = CFHTTPMessageCreateRequest(NULL, (CFStringRef)@"GET", (__bridge CFURLRef)self.url, kCFHTTPVersion1_1);
+    CFHTTPMessageRef message = CFHTTPMessageCreateRequest(NULL, (CFStringRef)@"GET", (__bridge CFURLRef)self->currentUrl, kCFHTTPVersion1_1);
     
     if (seekStart > 0)
     {
@@ -235,6 +235,8 @@
     {
         CFRelease(message);
         
+        [self errorOccured];
+        
         return;
     }
     
@@ -242,6 +244,8 @@
     {
         CFRelease(message);
         
+        [self errorOccured];
+        
         return;
     }
     
@@ -274,6 +278,8 @@
         CFRelease(stream);
         CFRelease(message);
         
+        [self errorOccured];
+        
         return;
     }