Angular2-Meteor Observable Service

posts.service.ts

import { Injectable } from '@angular/core';
import { Meteor } from 'meteor/meteor';
import { MeteorComponent } from 'angular2-meteor';
import { BehaviorSubject } from 'rxjs/BehaviorSubject';

// Collections
import { Posts } from '/imports/collections/posts/collection';

/**
* @class PostsService
* @constructor
*/
@Injectable()
export class PostsService extends MeteorComponent {
  posts = new BehaviorSubject<Any>(null);
  /**
  * @method constructor
  */
  constructor() {
    super();
    this.subscribePosts();
  }
  /**
  * Subcription for posts for Posts service.
  * @method subscribePosts
  */
  subscribePosts() {
    this.subscribe('posts', () => {
      this.autorun(() => {
        this.posts.next(Posts.find().fetch());
      });
    });
  }
}