cypher-stream
Advanced tools
Comparing version 1.0.1-alpha to 1.0.2-alpha
{ | ||
"name": "cypher-stream", | ||
"version": "1.0.1-alpha", | ||
"version": "1.0.2-alpha", | ||
"description": "Streams cypher query results in a clean format", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -184,3 +184,3 @@ 'use strict'; | ||
it('can optionally return Neo4j data types', done => { | ||
it('can return Neo4j data types', done => { | ||
cypher(`match (n:Test) return n limit 1`, {}, { returnType: 'neo4j' }) | ||
@@ -187,0 +187,0 @@ .on('data', data => { |
@@ -333,2 +333,20 @@ 'use strict'; | ||
it.only('can return Neo4j data types', done => { | ||
var tx = cypher.transaction({ returnType: 'neo4j' }); | ||
tx.on('data', data => { | ||
data.should.have.properties([ | ||
'_fields', | ||
'keys', | ||
'length', | ||
'_fieldLookup', | ||
]); | ||
}); | ||
tx.write('MATCH (n:Test) return n LIMIT 1'); | ||
tx.commit(); | ||
tx.resume(); | ||
tx.on('end', done); | ||
}); | ||
}); |
@@ -12,3 +12,3 @@ 'use strict'; | ||
class TransactionStream extends Duplex { | ||
constructor(session) { | ||
constructor(session, options) { | ||
super({ objectMode: true }); | ||
@@ -26,3 +26,3 @@ | ||
} | ||
return $(new CypherStream(this.tx, statement)); | ||
return $(new CypherStream(this.tx, statement, options)); | ||
}) | ||
@@ -29,0 +29,0 @@ ; |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
43303
771