elytron - npm Package Compare versions

Comparing version 2.3.5 to 2.3.6

dist/src/produce/index.js

@@ -49,8 +49,10 @@ 'use strict';
 var handle_producer_close = function handle_producer_close(code, message_file_path, callback) {
-  (0, _logger.log)('Producer exited with code: ' + code);
+  var out = code == 0 ? _logger.log : _logger.error;
+  out('Producer exited with code: ' + code);
   _fs2.default.unlink(message_file_path, function (err) {
     if (err) throw err;
-    if (callback) callback();
     return true;
   });
+  if (callback) callback(code);
+  return code;
 };
@@ -57,0 +59,0 @@

package.json

 {
   "name": "elytron",
-  "version": "2.3.5",
+  "version": "2.3.6",
   "description": "An interface for Kafka in Node",
@@ -5,0 +5,0 @@ "main": "./dist/src/index.js",

src/produce/index.js

 import fs from 'fs';
 import uuid from 'uuid';
-import { log } from '../../lib/logger';
+import { log, error } from '../../lib/logger';
 import { BrokerError } from '../../lib/error';
@@ -30,8 +30,10 @@ import { kafkacat, tmp, brokers } from '../../lib/run';
 const handle_producer_close = (code, message_file_path, callback) => {
-  log(`Producer exited with code: ${code}`);
+  const out = code == 0 ? log : error;
+  out(`Producer exited with code: ${code}`);
   fs.unlink(message_file_path, (err) => {
     if (err) throw err;
-    if (callback) callback();
     return true;
   });
+  if (callback) callback(code);
+  return code;
 };
@@ -38,0 +40,0 @@

No alert changes

Improved metrics

Total package byte prevSize

41488

increased by0.29%

Lines of code

677

increased by0.59%

No dependency changes