MLIBZ-2323: Don't swallow error when using observable (#302)

src/core/datastore/cachestore.spec.js

@@ -109,6 +109,25 @@ describe('CacheStore', () => {
         });
     });
 
+    it('should throw an error if trying to access a property on undefined', (done) => {
+      const store = new CacheStore(collection);
+      const onNextSpy = expect.createSpy();
+
+      store.find()
+        .subscribe((entities) => {
+          return entities[0].name;
+        }, (error) => {
+          try {
+            expect(error).toBeA(TypeError);
+            done();
+          } catch (e) {
+            done(e);
+          }
+        }, () => {
+          done(new Error('This test should fail.'));
+        });
+    });
+
     it('should return the entities', (done) => {
       const entity1 = { _id: randomString() };
       const entity2 = { _id: randomString() };

src/core/observable.js

@@ -128,7 +128,7 @@ class SafeSubscriber extends Subscriber {
     try {
       fn.call(this._context, value);
     } catch (err) {
-      this.unsubscribe();
+      this.error(err);
       throw err;
     }
   }