Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
let buildStream = (key) => {
let stream = new Writable;
// $FlowFixMe: TODO add to flow definition
stream.columns = 1000;
// $FlowFixMe: TODO ditto
stream.write = (msg) => {
stream.emit("data", msg);
data[key] += msg;
};
return stream;
};
const buildStream = (key): Writable => {
const stream = new Writable();
// $FlowFixMe: TODO add to flow definition
stream.columns = 1000;
// $FlowFixMe: TODO ditto
stream.write = msg => {
stream.emit('data', msg);
data[key] += msg;
};
return stream;
};
let buildStream = (key) => {
let stream = new Writable;
stream.columns = 1000;
stream.write = (msg) => {
stream.emit("data", msg);
data[key] += msg;
};
return stream;
};
const Writable = cb => {
const writable = new Stream.Writable({ objectMode: true })
writable._write = (chunk, _, done) => {
assert.strictEqual(chunk, 'A')
done()
cb && cb()
}
return writable
}
function createMockWriteStream () {
const s = new Stream.Writable()
s._data = ''
s._write = function (chunk, encoding, done) {
s._data += chunk.toString()
done()
}
return s
}