diff --git a/storage/file.js b/storage/file.js
index 92e8cceee..b55ba3051 100644
--- a/storage/file.js
+++ b/storage/file.js
@@ -975,10 +975,11 @@ var trimChannel = function (env, channelName, hash, _cb) {
             if (msgHash === hash) {
                 // everything from this point on should be retained
                 retain = true;
-                return void tempStream.write(msgObj.buff, function () {
+                return void tempStream.write(s_msg + '\n', function () {
                     readMore();
                 });
             }
+            readMore();
         };
 
         readMessagesBin(env, channelName, 0, handler, w(function (err) {