Method constructor

lib/DataHandler.ts:44–65

(private redis: DataHandledable, parserOptions: ParserOptions)

export default class DataHandler {
  constructor(private redis: DataHandledable, parserOptions: ParserOptions) {
    const parser = new RedisParser({
      stringNumbers: parserOptions.stringNumbers,
      returnBuffers: true,
      returnError: (err: Error) => {
        this.returnError(err);
      },
      returnFatalError: (err: Error) => {
        this.returnFatalError(err);
      },
      returnReply: (reply: any) => {
        this.returnReply(reply);
      },
    });

    // prependListener ensures the parser receives and processes data before socket timeout checks are performed
    redis.stream.prependListener("data", (data) => {
      parser.execute(data);
    });
    // prependListener() doesn't enable flowing mode automatically - we need to resume the stream manually
    redis.stream.resume();
  }

  private returnFatalError(err: Error) {
    err.message += ". Please report this.";