import { WorkerPro } from "@taskforcesh/bullmq-pro"
import {Â Observable } from "rxjs"
const processor = async () => {
return new Observable<number>(subscriber => {
const intervalId = setTimeout(() => {
// Provide a way of canceling and disposing the interval resource
return function unsubscribe() {
clearInterval(intervalId);
const worker = new WorkerPro(queueName, processor, { connection });