|
|
|
@ -851,7 +851,7 @@ var trimChannel = function (env, channelName, hash, _cb) { |
|
|
|
var retain = false; |
|
|
|
|
|
|
|
var handler = function (msgObj, readMore, abort) { |
|
|
|
if (ABORT) { return void abort(); } // XXX
|
|
|
|
if (ABORT) { return void abort(); } |
|
|
|
// the first message might be metadata... ignore it if so
|
|
|
|
if (i++ === 0 && msgObj.buff.indexOf('{') === 0) { |
|
|
|
return readMore(); |
|
|
|
|