Method flush

src/emulator/types.ts:352–376

()

  }

  private flush(): void {
    const nextMsg = EmulatorLog.LOG_BUFFER.shift();
    if (!nextMsg) {
      return;
    }

    EmulatorLog.WAITING_FOR_FLUSH = true;
    if (process.send) {
      // For some reason our node.d.ts file does not include the version of subprocess.send() with a callback
      // but the node docs assert that it has an optional callback.
      // https://nodejs.org/api/child_process.html#child_process_subprocess_send_message_sendhandle_options_callback
      (process.send as any)(nextMsg, undefined, {}, (err: any) => {
        if (err) {
          process.stderr.write(err);
        }

        EmulatorLog.WAITING_FOR_FLUSH = EmulatorLog.LOG_BUFFER.length > 0;
        this.flush();
      });
    } else {
      process.stderr.write(
        "subprocess.send() is undefined, cannot communicate with Functions Runtime.",
      );
    }
  }

  private toStringCore(pretty = false): string {
    return JSON.stringify(