Skip to content

Commit bc577f0

Browse files
committed
stream emits save
1 parent f22b84e commit bc577f0

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

lib/stream.js

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,9 +161,16 @@
161161
}
162162
cache.stream = true;
163163

164+
// Same emit format as 'save' in nddb.js
165+
this.emit('save', conf, {
166+
stream: true,
167+
file: filename,
168+
format: conf.format,
169+
journal: !!opts.journal
170+
});
171+
164172
let stream = new Stream({
165173
filename: filename,
166-
conf: conf,
167174
nddb: this,
168175
journal: !!opts.journal,
169176
conf: conf

0 commit comments

Comments
 (0)