libkazv
|
Listen on the event stream. More...
#include <old_sync.hpp>
Classes | |
class | JobResponse |
Public Member Functions | |
GetEventsJob (std::string serverUrl, std::string _accessToken, std::optional< std::string > from=std::nullopt, std::optional< int > timeout=std::nullopt) | |
Listen on the event stream. More... | |
GetEventsJob | withData (JsonWrap j) && |
GetEventsJob | withData (JsonWrap j) const & |
![]() | |
BaseJob (std::string serverUrl, std::string requestUrl, Method method, std::string jobId, std::string token={}, ReturnType returnType=ReturnType::Json, Body body=EmptyBody{}, Query query={}, Header header={}, std::optional< FileDesc > responseFile=std::nullopt) | |
~BaseJob () | |
bool | shouldReturnJson () const |
std::string | url () const |
Body | requestBody () const |
Header | requestHeader () const |
ReturnType | returnType () const |
Query | requestQuery () const |
returns the non-encoded query as an array of pairs More... | |
Method | requestMethod () const |
Response | genResponse (Response r) const |
BaseJob | withData (JsonWrap j) && |
BaseJob | withData (JsonWrap j) const & |
BaseJob | withQueue (std::string id, JobQueuePolicy policy=AlwaysContinue) && |
BaseJob | withQueue (std::string id, JobQueuePolicy policy=AlwaysContinue) const & |
json | dataJson (const std::string &key) const |
std::string | dataStr (const std::string &key) const |
std::string | jobId () const |
std::optional< std::string > | queueId () const |
JobQueuePolicy | queuePolicy () const |
std::optional< FileDesc > | responseFile () const |
Static Public Member Functions | |
static constexpr auto | needsAuth () |
static BaseJob::Query | buildQuery (std::optional< std::string > from, std::optional< int > timeout) |
static BaseJob::Body | buildBody (std::optional< std::string > from, std::optional< int > timeout) |
![]() | |
static bool | contentTypeMatches (immer::array< std::string > expected, std::string actual) |
Additional Inherited Members | |
![]() | |
enum | ReturnType { Json , File } |
using | Method = std::variant< Get, Post, Put, Delete > |
using | Body = ::Kazv::Body |
using | BytesBody = ::Kazv::BytesBody |
using | JsonBody = ::Kazv::JsonBody |
using | EmptyBody = ::Kazv::EmptyBody |
using | Header = ::Kazv::Header |
using | Response = ::Kazv::Response |
![]() | |
static Get | GET {} |
static Post | POST {} |
static Put | PUT {} |
static Delete | DELETE {} |
![]() | |
void | attachData (JsonWrap data) |
Listen on the event stream.
This will listen for new events and return them to the caller. This will block until an event is received, or until the timeout
is reached.
This endpoint was deprecated in r0 of this specification. Clients should instead call the /sync
endpoint with a since
parameter. See the migration guide.
|
explicit |
Listen on the event stream.
from | The token to stream from. This token is either from a previous request to this API or from the initial sync API. |
timeout | The maximum time in milliseconds to wait for an event. |
|
static |
|
static |
|
inlinestaticconstexpr |
GetEventsJob Kazv::Api::GetEventsJob::withData | ( | JsonWrap | j | ) | && |
GetEventsJob Kazv::Api::GetEventsJob::withData | ( | JsonWrap | j | ) | const & |