Subject Observer Example

FilterService.ts

import {Observer} from 'rxjs/Observer';
import {Subject} from 'rxjs/Subject';

export class FilterService {

  private subject: Subject = new Subject();
  private _name: string;
  private _tags: CollectionMatcher = {
    values: [],
    allMustMatch: false
  };
  
  get name(): string {
    return this._name;
  }

  set name(name: string) {
    this._name = name;
    this.subject.next(null);
  }

  get tags(): CollectionMatcher {
    return this._tags;
  }

  set tags(item: CollectionMatcher) {
    this._tags = item;
    this.subject.next(null);
  }

  subscribe(observer: Observer): ISubscription {
    return this.subject.subscribe(observer);
  }
}

ObserverImpl.ts

class ObserverImpl implements Observer {

  public next(result: any) {
    console.log(`result: ${result}`);
  };

  public error(err: any) {
    console.log(`error: ${err}`);
  };

  public complete() {
    console.log('Completed');
  }
}

SomeClass.ts

import {FilterService} from './FilterService';
import {ObserverImpl} from './ObserverImpl';

export class SomeClass {

  private subscription: ISubscription;

  constructor(private filterService: FilterService, private $scope: any) {
    this.subscription = this.filterService.subscribe(new ObserverImpl());
    $scope.$on('$destroy', () => this.subscription.unsubscribe();
  }
  
  /* moar stuff  */
  
}