pg-native - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

index.js

@@ -51,10 +51,19 @@ var Libpq = require('libpq');
 
-var dispatchQuery = function(pq, fn, cb) {
-  setImmediate(function() {
-    var sent = fn();
-    if(!sent) return cb(new Error(pq.errorMessage()));
-    cb();
+var waitForDrain = function(pq, cb) {
+  var res = pq.flush();
+  if(res === 0) return cb();
+  if(res === -1) return cb(pq.errorMessage());
+  return pq.writable(function() {
+    waitForDrain(pq, cb);
   });
 };
 
+var dispatchQuery = function(pq, fn, cb) {
+  var success = pq.setNonBlocking(true);
+  if(!success) return cb(new Error('Unable to set non-blocking to true'));
+  var sent = fn();
+  if(!sent) return cb(new Error(pq.errorMessage()));
+  return waitForDrain(pq, cb);
+};
+
 var consumeResults = function(pq, cb) {
@@ -61,0 +70,0 @@ var cleanup = function() {

package.json

 {
   "name": "pg-native",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "A slightly nicer interface to Postgres over node-libpq",
@@ -25,3 +25,3 @@ "main": "index.js",
   "dependencies": {
-    "libpq": "^0.2.4",
+    "libpq": "0.2.5",
     "pg-types": "^1.4.0"
@@ -28,0 +28,0 @@ },

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

8075

increased by13.84%

Number of package files

10

increased by25%

Lines of code

266

increased by13.68%

Dependency changes

• Updatedlibpq@0.2.5