Merge branch 'soon' into staging
This commit is contained in:
commit
4f1ed242a3
@ -162,6 +162,7 @@ const mkOffsetCounter = () => {
|
|||||||
|
|
||||||
const readMessagesBin = (env, id, start, msgHandler, cb) => {
|
const readMessagesBin = (env, id, start, msgHandler, cb) => {
|
||||||
const stream = Fs.createReadStream(mkPath(env, id), { start: start });
|
const stream = Fs.createReadStream(mkPath(env, id), { start: start });
|
||||||
|
// TODO get the channel and add the atime
|
||||||
let keepReading = true;
|
let keepReading = true;
|
||||||
Pull(
|
Pull(
|
||||||
ToPull.read(stream),
|
ToPull.read(stream),
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user