import { Component, inject, signal } from "@angular/core";
import { MarkpdfService } from "@markpdf/angular";

@Component({
  selector: "app-stream-viewer",
  standalone: true,
  template: `<pre>{{ text() }}</pre>`,
})
export class StreamViewerComponent {
  private markpdf = inject(MarkpdfService);
  text = signal("");

  loadFromUrl(url: string) {
    this.text.set("");
    this.markpdf.convertStream({ url }).subscribe({
      next: (chunk) => this.text.update((t) => t + chunk),
      error: (err) => console.error(err),
      complete: () => console.log("stream terminado"),
    });
  }
}

import { scan } from "rxjs/operators";

markdown$ = this.markpdf
  .convertStream({ url })
  .pipe(scan((acc, chunk) => acc + chunk, ""));

<pre>{{ markdown$ | async }}</pre>

import { catchError, delay, expand, takeWhile } from "rxjs/operators";
import { of, throwError } from "rxjs";

pollJob(jobId: string) {
  return this.markpdf.getJob(jobId).pipe(
    expand((status) =>
      status.status === "queued" || status.status === "processing"
        ? this.markpdf.getJob(jobId).pipe(delay(5000))
        : of(status).pipe(takeWhile(() => false, true))
    ),
    takeWhile((status) => status.status !== "completed" && status.status !== "failed", true)
  );
}

this.markpdf.convertFile(file).subscribe({
  next: (result) => {
    if (typeof result === "object" && "jobId" in result) {
      this.pollJob(result.jobId).subscribe((status) => {
        if (status.status === "completed") this.markdown.set(status.body as string);
        if (status.status === "failed") console.error(status.error);
      });
    } else {
      this.markdown.set(result as string);
    }
  },
});