kafka-observe - npm Package Compare versions

Comparing version 2.1.1-beta-6 to 2.1.1-beta-7

controllers/stream.controller.js

@@ -32,6 +32,6 @@ const { filter } = require("rxjs/operators");
 	},
-	read: ({ consumer }) => ({ topic, events, filter, onStatus }) => new Promise((resolve, reject) => {
+	read: ({ consumer }) => ({ topic, events, guard, onStatus }) => new Promise((resolve, reject) => {
 		let result = {};
 		const subscription = consumer.getTopicSubject(topic)
-			.pipe(filter(item => events.includes(item.event) && (filter ? filter(item) : true))
+			.pipe(filter(item => events.includes(item.event) && (guard ? guard(item) : true))
 				.subscribe((item => {
@@ -38,0 +38,0 @@ if (item.error) {

index.js

@@ -118,3 +118,3 @@ const { Consumer, ConsumerGroup, Producer } = require("./IO");
 		 * @param {String} event The event to listen for
-		 * @param {Function} filter filter function to filter stream
+		 * @param {Function} guard guard function to guard stream from reading
 		 * @param {Function} onStatus Callback will be called with status about the stream
@@ -121,0 +121,0 @@ */

package.json

 {
   "name": "kafka-observe",
-  "version": "2.1.1-beta-6",
+  "version": "2.1.1-beta-7",
   "description": "",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -119,3 +119,3 @@ # kafka-observe
     events: ["listen_for_event"],
-    filter: () => true,
+    guard: () => true,
     onStatus: (status) => console.log(status) // A callback to receive status about the stream 
@@ -122,0 +122,0 @@ }).then((event) => {

No alert changes

Improved metrics

Total package byte prevSize

32055

increased by0.02%

No dependency changes