.subscribe(poemId => {
                this.poemId = poemId;

                // Subscribe to this poem
                if (this.poemSub) {
                    this.poemSub.unsubscribe();
                }

                this.poemSub = MeteorObservable.subscribe('poems', {}, {
                        poemId: this.poemId
                    })
                .subscribe(() => {
                    this.poem = Poems.findOne(this.poemId);
                });

                // Subscribe to the list of contributors for this poem
                if (this.contributorSub) {
                    this.contributorSub.unsubscribe();
                }

                this.contributorSub = MeteorObservable.subscribe('contributors', this.poemId)
                    .subscribe(() => {
                        this.contributors = Users.find({}).zone();
                    });
            });

  subscribeUsers(): Subscription {
    // Fetch all users matching search pattern
    const subscription = MeteorObservable.subscribe('users', this.searchPattern.getValue());
    const autorun = MeteorObservable.autorun();

    return Observable.merge(subscription, autorun).subscribe(() => {
      this.users = this.findUsers();
    });
  }

  private handleRemove(alert): void {
    MeteorObservable.call('removeChat', this.params.get('chat')._id).subscribe({
      next: () => {

       alert.dismiss().then(() => {
          this.navCtrl.setRoot(ChatsPage, {}, {
            animate: true
          });
        });
      },

     error: (e: Error) => {
        alert.dismiss().then(() => {
          if (e) {
            return this.handleError(e);
          }

          this.navCtrl.setRoot(ChatsPage, {}, {

           animate: true
          });
        });
      }
    });
  }

 reply(rsvp: string) {
   MeteorObservable.call('reply', this.track._id, rsvp).subscribe(() => {
     alert('You successfully replied.');
   }, (error) => {
     alert(`Failed to reply due to ${error}`);
   });
 }

 invite(user: Meteor.User) {
   MeteorObservable.call('invite', this.track._id, user._id).subscribe(() => {
     alert('User successfully invited.');
   }, (error) => {
     alert(`Failed to invite due to ${error}`);
   });
 }

 ngOnInit() {
   this.usersSub = MeteorObservable.subscribe('pipeUsers').subscribe(() => {
     MeteorObservable.autorun().subscribe(() => {
       this.users = this._userService.findUsers();
     });
   });
 }

 ngOnInit() {
   MeteorObservable.subscribe('users').subscribe(() => {
     MeteorObservable.autorun().subscribe(() => {
       this.users = this.findUsers().zone();
     });
   });
 }

 ngOnInit() {
   this.todos = Todos.find();
   // Subscribe and connect it to Angular's change detection system
   // while running on client
   if (Meteor.isClient)
     this.todoListSubscription = MeteorObservable.subscribe('todoList').subscribe();
 }

        this.versionSub = MeteorObservable.subscribe('versions', this.versionId).zone().subscribe(() => {
          MeteorObservable.autorun().subscribe(() => {
            this.version = this._versionService.getVersionById(versionId);

            this.nextVersion = this._versionService.getNextVersion(this.version.entity.entityId, this.version.version, this.version.taskType.type);
            this.prevVersion = this._versionService.getPrevVersion(this.version.entity.entityId, this.version.version, this.version.taskType.type);
          });
        });

 done(): void {
   MeteorObservable.call('updateProfile', this.profile).subscribe({
     next: () => {
       this.navCtrl.push(TabsPage);
     },
     error: (e: Error) => {
       this.handleError(e);
     }
   });
 }