A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
Loading...
Searching...
No Matches
fetch.cc File Reference
#include "a11/net/http/fetch.h"
#include <algorithm>
#include <cstdint>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
#include <utility>
#include <absl/status/status.h>
#include <absl/status/status_macros.h>
#include <absl/status/statusor.h>
#include <absl/strings/numbers.h>
#include <absl/strings/str_cat.h>
#include <absl/time/clock.h>
#include <absl/time/time.h>
#include <nlohmann/json.hpp>
#include "a11/concurrency/executor.h"
#include "a11/concurrency/future.h"
#include "a11/net/http/url.h"
#include "a11/net/http2.h"
#include "a11/status.h"

Namespaces

namespace  a11
 
namespace  a11::net
 
namespace  a11::net::internal
 

Functions

absl::StatusOr< HttpResponseHead > a11::net::internal::FetchBlocking (std::string url, FetchOptions options, const FetchSink &sink, const OnFetchProgress &on_progress={})
 The blocking core of FetchToSink, for a caller already on a fiber.
 
a11::Future< HttpResponse > a11::net::Fetch (std::string url, FetchOptions options={})
 Fetches url and buffers the whole response.
 
a11::Future< HttpResponseHead > a11::net::FetchToSink (std::string url, FetchSink sink, FetchOptions options={}, OnFetchProgress on_progress={})
 Fetches url and hands the body to sink as it arrives.