minor changes in avro

moleculerjs · Apr 4, 2017 · 8e70116 · 8e70116
1 parent c1aa9cc
commit 8e70116
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/benchmark/perf-runner.js b/benchmark/perf-runner.js
@@ -5,7 +5,7 @@ const v8 = require('v8-natives');
 let ServiceBroker = require("../src/service-broker");
 let Context = require("../src/context");
 let Transporters = require("../src/transporters");
-let Serializer = require("../src/serializers/avro");
+let Serializer = require("../src/serializers/json");
 
 let { generateToken, json2String } = require("../src/utils");
 let Promise	= require("bluebird");

diff --git a/src/serializers/avro.js b/src/serializers/avro.js
@@ -115,8 +115,9 @@ class AvroSerializer extends BaseSerializer {
 	 * @memberOf Serializer
 	 */
 	serialize(obj, type) {
-		const t = schemas[type].toBuffer(obj);
-		return t.toString("binary");
+		//const t = schemas[type].toBuffer(obj);
+		const t = schemas[type].toBuffer(obj).toString("binary");
+		return t;
 	}
 
 	/**
@@ -129,6 +130,7 @@ class AvroSerializer extends BaseSerializer {
 	 * @memberOf Serializer
 	 */
 	deserialize(str, type) {
+		//const res = schemas[type].fromBuffer(str);
 		const res = schemas[type].fromBuffer(Buffer.from(str, "binary"));
 		return res;
 	}