Commit abfacb93 authored by Tobias Steiner's avatar Tobias Steiner
Browse files

Just use the parsed values

parent 2f6478ff
...@@ -23,8 +23,7 @@ class Neo4jStreamWriter extends Writable { ...@@ -23,8 +23,7 @@ class Neo4jStreamWriter extends Writable {
} }
public async _write(chunk, encoding, callback) { public async _write(chunk, encoding, callback) {
console.log(chunk); const query = this.buildQuery(chunk.parsed);
const query = this.buildQuery(chunk);
const neo4jSession: Session = this.neo4j.session(); const neo4jSession: Session = this.neo4j.session();
try { try {
await neo4jSession.run(query); await neo4jSession.run(query);
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment