Comparing version 1.11.0-1 to 1.11.0-2
27
net.js
@@ -328,2 +328,9 @@ // Generated by CoffeeScript 1.4.0 | ||
} | ||
if (opts.durability != null) { | ||
pair = { | ||
key: 'durability', | ||
val: r.expr(opts.durability).build() | ||
}; | ||
query.global_optargs.push(pair); | ||
} | ||
if ((!(opts.noreply != null)) || !opts.noreply) { | ||
@@ -361,11 +368,17 @@ this.outstandingCallbacks[token] = { | ||
Connection.prototype._sendQuery = function(query) { | ||
var data, i, totalBuf; | ||
var data, i, lengthBuffer, totalBuf; | ||
query.accepts_r_json = true; | ||
data = pb.SerializeQuery(query); | ||
totalBuf = new Buffer(data.length + 4); | ||
totalBuf.writeUInt32LE(data.length, 0); | ||
i = 0; | ||
while (i < data.length) { | ||
totalBuf.set(i + 4, data.get(i)); | ||
i++; | ||
if (pb.protobuf_implementation === 'cpp') { | ||
lengthBuffer = new Buffer(4); | ||
lengthBuffer.writeUInt32LE(data.length, 0); | ||
totalBuf = Buffer.concat([lengthBuffer, data]); | ||
} else { | ||
totalBuf = new Buffer(data.length + 4); | ||
totalBuf.writeUInt32LE(data.length, 0); | ||
i = 0; | ||
while (i < data.length) { | ||
totalBuf.set(i + 4, data.get(i)); | ||
i++; | ||
} | ||
} | ||
@@ -372,0 +385,0 @@ return this.write(totalBuf); |
{ "name" : "rethinkdb" | ||
, "version" : "1.11.0-1" | ||
, "version" : "1.11.0-2" | ||
, "main" : "rethinkdb" | ||
@@ -4,0 +4,0 @@ , "description" : "This package provides the JavaScript driver library for the RethinkDB database server for use either from node or your web-browser." |
Sorry, the diff of this file is too big to display
150766
4548