public async function writeAllAsync()

in src/io/WriteHandleConvenienceMethodsTrait.php [22:65]

38 lines of code
7 McCabe index (conditional complexity)


  public async function writeAllAsync(
    string $data,
    ?int $timeout_ns = null,
  ): Awaitable<void> {
    if ($data === '') {
      return;
    }

    _OS\arg_assert(
      $timeout_ns is null || $timeout_ns > 0,
      'Timeout must be null, or > 0',
    );

    $original_size = Str\length($data);

    $timer = new \HH\Lib\_Private\OptionalIncrementalTimeout(
      $timeout_ns,
      () ==> {
        _OS\throw_errno(
          OS\Errno::ETIMEDOUT,
          "Reached timeout before %s data could be read.",
          $data === '' ? 'any' : 'all',
        );
      },
    );

    do {
      /* @lint-ignore AWAIT_IN_LOOP */
      $written = await $this->writeAllowPartialSuccessAsync(
        $data,
        $timer->getRemainingNS(),
      );
      $data = Str\slice($data, $written);
    } while ($written !== 0 && $data !== '');

    if ($data !== '') {
      _OS\throw_errno(
        OS\Errno::EPIPE,
        "asked to write %d bytes, but only able to write %d bytes",
        $original_size,
        $original_size - Str\length($data),
      );
    }
  }