Function executeSharedPropertyObserverTests

test/shared.js:53–185

(obj, observer, done)

}

export function executeSharedPropertyObserverTests(obj, observer, done) {
  let context = 'test-context';
  let callable0 = { call: jasmine.createSpy('callable0') };
  let callable1 = { call: jasmine.createSpy('callable1') };
  let callable2 = { call: jasmine.createSpy('callable2') };
  let callable3 = { call: jasmine.createSpy('callable3') };
  let callable4 = { call: jasmine.createSpy('callable4') };
  let callable5 = { call: jasmine.createSpy('callable5') };
  let oldValue;
  let newValue;
  let values = ['alkjdfs', 0, false, {}, [], null, undefined, 'foo'];
  let next;
  spyOn(observer, 'addSubscriber').and.callThrough();
  spyOn(observer, 'removeSubscriber').and.callThrough();
  // hasSubscribers, hasSubscriber
  expect(observer.hasSubscribers()).toBe(false);
  expect(observer.hasSubscriber(context, callable0)).toBe(false);
  observer.subscribe(context, callable0);
  expect(observer.addSubscriber).toHaveBeenCalledWith(context, callable0);
  expect(countSubscribers(observer)).toBe(1);
  expect(observer.hasSubscribers()).toBe(true);
  expect(observer.hasSubscriber(context, callable0)).toBe(true);
  // doesn't allow multiple subscribe
  observer.subscribe(context, callable0);
  expect(observer.addSubscriber).toHaveBeenCalledWith(context, callable0);
  expect(countSubscribers(observer)).toBe(1);
  // doesn't allow multiple unsubscribe
  observer.unsubscribe(context, callable0);
  expect(observer.removeSubscriber).toHaveBeenCalledWith(context, callable0);
  expect(countSubscribers(observer)).toBe(0);
  observer.unsubscribe(context, callable0);
  expect(observer.removeSubscriber).toHaveBeenCalledWith(context, callable0);
  expect(countSubscribers(observer)).toBe(0);

  // overflows into "rest" array
  observer.subscribe(context, callable0);
  expect(observer._callable0).toBe(callable0);
  expect(countSubscribers(observer)).toBe(1);
  expect(observer.hasSubscribers()).toBe(true);
  expect(observer.hasSubscriber(context, callable0)).toBe(true);

  observer.subscribe(context, callable1);
  expect(observer._callable1).toBe(callable1);
  expect(countSubscribers(observer)).toBe(2);
  expect(observer.hasSubscribers()).toBe(true);
  expect(observer.hasSubscriber(context, callable1)).toBe(true);

  observer.subscribe(context, callable2);
  expect(observer._callable2).toBe(callable2);
  expect(countSubscribers(observer)).toBe(3);
  expect(observer.hasSubscribers()).toBe(true);
  expect(observer.hasSubscriber(context, callable2)).toBe(true);

  observer.subscribe(context, callable3);
  expect(observer._callablesRest[0]).toBe(callable3);
  expect(countSubscribers(observer)).toBe(4);
  expect(observer.hasSubscribers()).toBe(true);
  expect(observer.hasSubscriber(context, callable3)).toBe(true);