Class

src/job-queue/redis-adapter.ts:5–5

import { Queue, QueueOptions } from "./queue"

export class RedisQueue<T> extends Queue<T> {
  private redisBlocking: IORedis
  private redisNonBlocking: IORedis
  private redisSubscriber: IORedis