Meteor MiniMongo Cursor to RxJS Observable

cursor-to-observable.ts

import { Mongo } from 'meteor/mongo';
import {Observable, Subscriber} from "rxjs";

function toObservable<T>(cursor : Mongo.Cursor<T>) : Observable<T> {
  return Observable.create((observer : Subscriber) => {
    const handleChange = () => {
      observer.next(cursor.fetch());
    };

    let handler = cursor.observe({
      added: handleChange,
      changed: handleChange,
      removed: handleChange
    });

    return () => {
      handler.stop();
    }
  })
}