Function read

src/Routers/FilesRouter.js:24–60

()

  const output = new Readable({
    read() {
      if (!started) {
        started = true;

        onData = (chunk) => {
          totalBytes += chunk.length;
          if (totalBytes > maxBytes) {
            output.destroy(
              new Parse.Error(
                Parse.Error.FILE_SAVE_ERROR,
                `File size exceeds maximum allowed: ${maxBytes} bytes.`
              )
            );
            return;
          }
          if (!output.push(chunk)) {
            source.pause();
          }
        };

        onEnd = () => {
          sourceEnded = true;
          output.push(null);
        };

        onError = (err) => output.destroy(err);

        source.on('data', onData);
        source.on('end', onEnd);
        source.on('error', onError);
      }

      // Resume source in case it was paused due to backpressure
      if (!sourceEnded) {
        source.resume();
      }
    },
    destroy(err, callback) {
      if (onData) {
        source.removeListener('data', onData);