READY,
    NOT_READY,
    DONE,
    FAILED,
  }

  private @Nullable T next;

  protected abstract @Nullable T computeNext();

  @CanIgnoreReturnValue
  protected final @Nullable T endOfData() {
    state = State.DONE;
    return null;
  }

  @Override
  public final boolean hasNext() {
    checkState(state != State.FAILED);
    switch (state) {
      case DONE:
        return false;

            if (logger.isInfoEnabled()) {
                logger.info("Backup file uploaded successfully and queued for import: fileName={}, tempFile={}", fileName,
                        tempFile.getAbsolutePath());
            }
        } catch (final IOException e) {
            logger.warn("Failed to upload backup file: fileName={}, error={}", fileName, e.getMessage(), e);

                    }
                } else {
                    logger.warn("Failed to send {} to {}. HTTP Status is {}. {}", body, url, response.getHttpStatusCode(),
                            response.getContentAsString());
                }
            } catch (final IOException e) {
                logger.warn("Failed to send {} to {}.", body, url, e);
            }
        }));
    }

    /**

else
  tar xzf${__MVNW_QUIET_TAR:+"$__MVNW_QUIET_TAR"} "$TMP_DOWNLOAD_DIR/$distributionUrlName" -C "$TMP_DOWNLOAD_DIR" || die "failed to untar"
fi
printf %s\\n "$distributionUrl" >"$TMP_DOWNLOAD_DIR/$distributionUrlNameMain/mvnw.url"
mv -- "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" "$MAVEN_HOME" || [ -d "$MAVEN_HOME" ] || die "fail to move MAVEN_HOME"

clean || :

    // Due to the implementation of the two services we know that both are now failed.  So the
    // following awaitHealthy call is just to get the exception.
    manager.startAsync();
    assertThat(manager.servicesByState().get(State.FAILED)).hasSize(2);
    IllegalStateException e = assertThrows(IllegalStateException.class, manager::awaitHealthy);
    assertThat(e)

                .execute()) {
            if (response.getHttpStatusCode() != 200 && response.getHttpStatusCode() != 201) {
                logger.warn("Failed to send heartbeat: status={}", response.getHttpStatusCode());
            }
        } catch (final Exception e) {
            logger.debug("Failed to send heartbeat.", e);
        }
    }

    /**
     * Removes the heartbeat document for this instance from OpenSearch.
     */

                        })
                        .orElse(false);

                // Check if any predecessor failed - if so, we'll run the step but mark it as SKIPPED
                boolean anyPredecessorFailed = step.predecessors.stream().anyMatch(s -> s.status.get() == FAILED);

                // If any predecessor failed, we'll use a special status transition: CREATED -> SKIPPED

                            logger.debug("Log file: name={}, size={}", filePath.getFileName(), len);
                        }
                    } catch (final IOException e) {
                        logger.warn("Failed to access {}", filePath, e);
                    }
                });
            } catch (final Exception e) {
                logger.warn("Failed to access log files.", e);
            }
        }

			t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err)
		}
	}
	if gr != nil {
		_, err = io.Copy(io.Discard, gr)
		if err != toObjectErr(errErasureReadQuorum, bucket, object) {
			t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err)
		}
		gr.Close()

    /** Kerberos AP-REQ message type */
    String KERBEROS_AP_REQ = "14";

    /** Address family: Internet (IPv4) */
    int AF_INTERNET = 2;
    /** Address family: CHANET */
    int AF_CHANET = 5;
    /** Address family: XNS */
    int AF_XNS = 6;
    /** Address family: ISO */
    int AF_ISO = 7;

    /** Authorization data type: Relevant */
    int AUTH_DATA_RELEVANT = 1;