A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
Loading...
Searching...
No Matches
a11::net::internal Namespace Reference

Functions

OnMessage GuardOnMessage (OnMessage callback)
 
OnDone GuardOnDone (OnDone callback)
 
Http2RequestHandler GuardRequestHandler (Http2RequestHandler handler)
 
OnWebSocketStream GuardOnWebSocketStream (OnWebSocketStream callback)
 
OnSignallingMessage GuardOnSignallingMessage (OnSignallingMessage callback)
 
OnHttpSseConnect GuardOnHttpSseConnect (OnHttpSseConnect callback)
 
absl::StatusOr< HttpResponseHead > 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.
 

Function Documentation

◆ FetchBlocking()

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.

FetchToSink() is this plus an a11::Submit. A caller that is itself running inside a Submit – Download(), for one – uses this directly rather than spending a second fiber to block the first one against.

Warning
Blocks. Never call it on the libuv loop thread.

◆ GuardOnDone()

OnDone a11::net::internal::GuardOnDone ( OnDone  callback)

◆ GuardOnHttpSseConnect()

OnHttpSseConnect a11::net::internal::GuardOnHttpSseConnect ( OnHttpSseConnect  callback)

◆ GuardOnMessage()

OnMessage a11::net::internal::GuardOnMessage ( OnMessage  callback)

◆ GuardOnSignallingMessage()

OnSignallingMessage a11::net::internal::GuardOnSignallingMessage ( OnSignallingMessage  callback)

◆ GuardOnWebSocketStream()

OnWebSocketStream a11::net::internal::GuardOnWebSocketStream ( OnWebSocketStream  callback)

◆ GuardRequestHandler()

Http2RequestHandler a11::net::internal::GuardRequestHandler ( Http2RequestHandler  handler)