diff --git a/Audjustable/Classes/AudioPlayer/CoreFoundationDataSource.m b/Audjustable/Classes/AudioPlayer/CoreFoundationDataSource.m
index b6c52ad..50d8c7a 100644
--- a/Audjustable/Classes/AudioPlayer/CoreFoundationDataSource.m
+++ b/Audjustable/Classes/AudioPlayer/CoreFoundationDataSource.m
@@ -81,7 +81,7 @@ static void ReadStreamCallbackProc(CFReadStreamRef stream, CFStreamEventType eve
     {
         [self unregisterForEvents];
         
-        CFReadStreamClose(stream);
+        [self close];
         
         stream = 0;
     }
@@ -92,6 +92,7 @@ static void ReadStreamCallbackProc(CFReadStreamRef stream, CFStreamEventType eve
     if (stream)
     {
         CFReadStreamClose(stream);
+        CFRelease(stream);
         
         stream = 0;
     }
diff --git a/Audjustable/Classes/AudioPlayer/HttpDataSource.m b/Audjustable/Classes/AudioPlayer/HttpDataSource.m
index ed28913..4b04003 100644
--- a/Audjustable/Classes/AudioPlayer/HttpDataSource.m
+++ b/Audjustable/Classes/AudioPlayer/HttpDataSource.m
@@ -96,9 +96,10 @@
     if (stream)
     {
         CFReadStreamClose(stream);
+        CFRelease(stream);
     }
     
-    stream = nil;
+    stream = 0;
     relativePosition = 0;
     seekStart = offset;
     
diff --git a/Audjustable/Classes/AudioPlayer/LocalFileDataSource.m b/Audjustable/Classes/AudioPlayer/LocalFileDataSource.m
index ae959d4..8f4ae64 100644
--- a/Audjustable/Classes/AudioPlayer/LocalFileDataSource.m
+++ b/Audjustable/Classes/AudioPlayer/LocalFileDataSource.m
@@ -77,6 +77,7 @@
     if (stream)
     {
         CFReadStreamClose(stream);
+        CFRelease(stream);
         
         stream = 0;
     }