bugfix(moved-to): Added missing callback and handler for moving items…

… inside a collection
Urigo · Oct 25, 2016 · e79af51 · e79af51
1 parent 24dc190
commit e79af51
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 0 deletions.
diff --git a/dist/ObservableCursor.d.ts b/dist/ObservableCursor.d.ts
@@ -18,6 +18,7 @@ export declare class ObservableCursor<T> extends Observable<T[]> {
     _addedAt(doc: any, at: any, before: any): void;
     _changedAt(doc: any, old: any, at: any): void;
     _removedAt(doc: any, at: any): void;
+    _movedTo(doc: any, fromIndex: any, toIndex: any): void;
     _handleChange(): void;
     _observeCursor(cursor: Mongo.Cursor<T>): any;
 }
diff --git a/dist/ObservableCursor.js b/dist/ObservableCursor.js
@@ -38,6 +38,7 @@ export var ObservableCursor = (function (_super) {
         if (this._hCursor) {
             this._hCursor.stop();
         }
+        this._data = [];
         this._hCursor = null;
     };
     ObservableCursor.prototype.dispose = function () {
@@ -77,6 +78,12 @@ export var ObservableCursor = (function (_super) {
         this._handleChange();
     };
     ;
+    ObservableCursor.prototype._movedTo = function (doc, fromIndex, toIndex) {
+        this._data.splice(fromIndex, 1);
+        this._data.splice(toIndex, 0, doc);
+        this._handleChange();
+    };
+    ;
     ObservableCursor.prototype._handleChange = function () {
         var _this = this;
         this._zone.run(function () {
@@ -89,6 +96,7 @@ export var ObservableCursor = (function (_super) {
         return gZone.run(function () { return cursor.observe({
             addedAt: _this._addedAt.bind(_this),
             changedAt: _this._changedAt.bind(_this),
+            movedTo: _this._movedTo.bind(_this),
             removedAt: _this._removedAt.bind(_this)
         }); });
     };

diff --git a/dist/bundles/index.umd.js b/dist/bundles/index.umd.js
@@ -93,6 +93,7 @@ var ObservableCursor = (function (_super) {
         if (this._hCursor) {
             this._hCursor.stop();
         }
+        this._data = [];
         this._hCursor = null;
     };
     ObservableCursor.prototype.dispose = function () {
@@ -132,6 +133,12 @@ var ObservableCursor = (function (_super) {
         this._handleChange();
     };
 
+    ObservableCursor.prototype._movedTo = function (doc, fromIndex, toIndex) {
+        this._data.splice(fromIndex, 1);
+        this._data.splice(toIndex, 0, doc);
+        this._handleChange();
+    };
+
     ObservableCursor.prototype._handleChange = function () {
         var _this = this;
         this._zone.run(function () {
@@ -144,6 +151,7 @@ var ObservableCursor = (function (_super) {
         return gZone.run(function () { return cursor.observe({
             addedAt: _this._addedAt.bind(_this),
             changedAt: _this._changedAt.bind(_this),
+            movedTo: _this._movedTo.bind(_this),
             removedAt: _this._removedAt.bind(_this)
         }); });
     };

diff --git a/src/ObservableCursor.ts b/src/ObservableCursor.ts
@@ -92,6 +92,12 @@ export class ObservableCursor<T> extends Observable<T[]> {
     this._handleChange();
   };
 
+  _movedTo(doc, fromIndex, toIndex) {
+    this._data.splice(fromIndex, 1);
+    this._data.splice(toIndex, 0, doc);
+    this._handleChange();
+  };
+
   _handleChange() {
     this._zone.run(() => {
       this._runNext(this._data);
@@ -103,6 +109,7 @@ export class ObservableCursor<T> extends Observable<T[]> {
       () => cursor.observe({
         addedAt: this._addedAt.bind(this),
         changedAt: this._changedAt.bind(this),
+        movedTo: this._movedTo.bind(this),
         removedAt: this._removedAt.bind(this)
       }));
   }