An implementation of a webcam processed by an observable.

webcam-observable.ts

export function initializeWebcam(
  videoElem: HTMLVideoElement,
  canvasElement: HTMLCanvasElement
) {
  return createWebcam(videoElem).pipe(
    switchMap(_ =>
      timer(0, 40).pipe(
        map(() => drawImageOnCanvas(videoElem, canvasElement))
      )
    )
  );
}