steveo - npm Package Compare versions

lib/consumers/base.d.ts

		@@ -5,3 +5,2 @@ import { Steveo } from '..';
		declare class BaseRunner {
		preProcess(): Promise<void>;
		createQueue(topic: string): Promise<boolean>;
		@@ -8,0 +7,0 @@ errorCount: number;

lib/consumers/base.js

		@@ -13,5 +13,2 @@ "use strict";
		class BaseRunner {
		async preProcess() {
		throw new Error('Unimplemented');
		}
		// @ts-ignore
		@@ -18,0 +15,0 @@ async createQueue(topic) {

lib/consumers/kafka.js

		@@ -81,3 +81,2 @@ "use strict";
		}
		await this.preProcess();
		if (err) {
		@@ -84,0 +83,0 @@ const message = 'Error while consumption';

package.json

		{
		"name": "steveo",
		"version": "6.0.0-beta1",
		"version": "6.0.0-beta2",
		"description": "A Task Pub/Sub Background processing library",
		"main": "lib/index.js",
		"author": "engineering@ordermentum.com",
		"private": false,
		"license": "Apache-2.0",
		@@ -49,5 +50,3 @@ "repository": "git@github.com:ordermentum/steveo.git",
		"null-logger": "^2.0.0",
		"uuid": "^9.0.0"
		},
		"peerDependencies": {
		"uuid": "^9.0.0",
		"aws-sdk": "^2.1043.0",
		@@ -57,2 +56,3 @@ "node-rdkafka": "^2.15.0",
		},
		"peerDependencies": {},
		"devDependencies": {
		@@ -59,0 +59,0 @@ "@emotion/eslint-plugin": "11.11",

New alerts