@@ -27,8 +27,7 @@ export function getObservers(type, collection, newDocument) {
27
27
} catch ( e ) {
28
28
console . error ( 'Error in observe callback old' , e ) ;
29
29
}
30
- }
31
- else {
30
+ } else {
32
31
// TODO what to do here?
33
32
}
34
33
}
@@ -56,7 +55,7 @@ const _registerObserver = (collection, cursor, callbacks) => {
56
55
observers [ collection ] = observers [ collection ] || [ ] ;
57
56
observers [ collection ] . push ( { cursor, callbacks } ) ;
58
57
59
- console . log ( observers )
58
+ console . log ( observers ) ;
60
59
} ;
61
60
62
61
class Cursor {
@@ -208,7 +207,7 @@ export class Collection {
208
207
} ) ;
209
208
} ) ;
210
209
}
211
- let observers = getObservers ( 'added' , this . _collection . name , item )
210
+ let observers = getObservers ( 'added' , this . _collection . name , item ) ;
212
211
observers . forEach ( callback => {
213
212
try {
214
213
callback ( item , undefined ) ;
@@ -224,7 +223,7 @@ export class Collection {
224
223
if ( typeof options == 'function' ) {
225
224
callback = options ;
226
225
}
227
- let old = this . _collection . get ( id )
226
+ let old = this . _collection . get ( id ) ;
228
227
if ( ! this . _collection . get ( id ) )
229
228
return callback ( {
230
229
error : 409 ,
@@ -247,17 +246,16 @@ export class Collection {
247
246
} ) ;
248
247
} ) ;
249
248
}
250
- let newItem = this . _collection . findOne ( { _id :id } )
249
+ let newItem = this . _collection . findOne ( { _id : id } ) ;
251
250
252
- let observers = getObservers ( 'changed' , this . _collection . name , newItem )
251
+ let observers = getObservers ( 'changed' , this . _collection . name , newItem ) ;
253
252
observers . forEach ( callback => {
254
253
try {
255
254
callback ( newItem , old ) ;
256
255
} catch ( e ) {
257
256
console . error ( 'Error in observe callback' , e ) ;
258
257
}
259
258
} ) ;
260
-
261
259
}
262
260
263
261
remove ( id , callback = ( ) => { } ) {
@@ -277,16 +275,15 @@ export class Collection {
277
275
} ) ;
278
276
} ) ;
279
277
}
280
-
281
- let observers = getObservers ( 'removed' , this . _collection . name , element )
278
+
279
+ let observers = getObservers ( 'removed' , this . _collection . name , element ) ;
282
280
observers . forEach ( callback => {
283
281
try {
284
- callback ( element ) ;
282
+ callback ( element ) ;
285
283
} catch ( e ) {
286
284
console . error ( 'Error in observe callback' , e ) ;
287
285
}
288
286
} ) ;
289
-
290
287
} else {
291
288
callback ( `No document with _id : ${ id } ` ) ;
292
289
}
0 commit comments