@live-change/framework - npm Package Compare versions

Comparing version 0.4.13 to 0.4.14

lib/utils/CommandQueue.js

@@ -45,2 +45,3 @@ const ReactiveDao = require('@live-change/dao')
     this.observable.observe(this)
+
     return new Promise((resolve, reject) => {
@@ -126,2 +127,9 @@ this.resolveStart = { resolve, reject }
   }
+  push(command) {
+    if(this.disposed) return
+    this.handleCommand({ ...command, id: command.id.slice(command.id.indexOf('_')+1) })
+  }
+  removeByField() {
+    /// Ignore
+  }
   error(error) {
@@ -128,0 +136,0 @@ if(this.resolveStart) {

lib/utils/EventSourcing.js

@@ -58,4 +58,6 @@ const EventsReader = require('./EventsReader.js')
     this.lastPositionSave = Date.now()
+    const savedPosition = this.state.position
     await this.connection.request(
         ['database', 'put'], this.database, 'eventConsumers', this.state)
+    this.lastSavedPosition = savedPosition
   }
@@ -98,3 +100,3 @@ async handleEvent(event, mainEvent) {
     if(Date.now() - this.lastPositionSave <= (this.config.saveThrottle || 1000)) {
-      setTimeout(() => this.savePosition(), this.config.saveThrottle)
+      setTimeout(() => this.savePosition(), this.config.saveThrottle || 1000)
       return
@@ -101,0 +103,0 @@ }

package.json

 {
   "name": "@live-change/framework",
-  "version": "0.4.13",
+  "version": "0.4.14",
   "description": "Live Change Framework - ultimate solution for real time mobile/web apps",
@@ -5,0 +5,0 @@ "main": "index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

159414

increased by0.17%

Lines of code

4375

increased by0.21%

No dependency changes