Method next

src/slave/task_status_update_manager.cpp:796–807

Result<StatusUpdate> TaskStatusUpdateStream::next()
{
  if (error.isSome()) {
    return Error(error.get());
  }

  if (!pending.empty()) {
    return pending.front();
  }

  return None();
}


Try<Nothing> TaskStatusUpdateStream::replay(