import { Repeater } from "@repeaterjs/repeater";
import { Observable } from "rxjs";

declare module 'rxjs' {
  interface Observable<T> {
    toIterator(): Repeater<T>;
  }
}

Observable.prototype.toIterator = function<T>() {
  return new Repeater<T>(async (push, stop) => {
    const subscription = this.subscribe({
      next(value) {
        push(value);
      },
      error(err) {
        stop(err);
      },
      complete() {
        stop();
      },
    });
    await stop;
    subscription.unsubscribe();
  });
};