@elastic.io/oih-standard-library
Advanced tools
Comparing version 0.0.10-dev.12 to 0.0.10-dev.13
@@ -184,3 +184,3 @@ "use strict"; | ||
this.logger.trace('Polled objects: %j', result); | ||
await this.emitIndividually(result.objects); | ||
await this.emitAll(result.objects); | ||
return result.nextPage; | ||
@@ -193,3 +193,3 @@ } | ||
async emitIndividually(results) { | ||
for (const r in results) { | ||
for (const r of results) { | ||
this.logger.trace('Emitting new message with body: %j', r); | ||
@@ -196,0 +196,0 @@ await this.emit('data', messages.newMessageWithBody(r)); |
@@ -199,3 +199,3 @@ import { | ||
this.logger.trace('Polled objects: %j', result); | ||
await this.emitIndividually(result.objects); | ||
await this.emitAll(result.objects); | ||
return result.nextPage; | ||
@@ -209,3 +209,3 @@ } | ||
public async emitIndividually(results: Array<any>) { | ||
for (const r in results) { | ||
for (const r of results) { | ||
this.logger.trace('Emitting new message with body: %j', r); | ||
@@ -212,0 +212,0 @@ await this.emit('data', messages.newMessageWithBody(r)); |
{ | ||
"name": "@elastic.io/oih-standard-library", | ||
"version": "0.0.10-dev.12", | ||
"version": "0.0.10-dev.13", | ||
"description": "Library for OIH standards implementation", | ||
@@ -5,0 +5,0 @@ "author": { |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
164262