Function processMessage

src/jrpc/jrpc.ts:106–120

(res: JRPCResponse<unknown>, _encoding: unknown, cb: (error?: Error | null) => void)

  }

  function processMessage(res: JRPCResponse<unknown>, _encoding: unknown, cb: (error?: Error | null) => void) {
    let err: Error;
    try {
      const isNotification = isJRPCNotification(res as JRPCNotification<JRPCParams> | JRPCRequest<JRPCParams>);
      if (isNotification) {
        processNotification(res as JRPCNotification<JRPCParams>);
      } else {
        processResponse(res);
      }
    } catch (_err: unknown) {
      err = _err as Error;
    }
    // continue processing stream
    cb(err);
  }

  const stream = new Duplex({
    objectMode: true,