yaze 0.3.2
Link to the Past ROM Editor
 
Loading...
Searching...
No Matches
Classes | Public Types | Public Member Functions | List of all members
yaze::app::platform::WasmMessageQueue Class Reference

#include <wasm_message_queue.h>

Classes

struct  QueuedMessage
 
struct  QueueStatus
 

Public Types

using ReplayCompleteCallback = std::function<void(int, int)>
 
using MessageSender = std::function<absl::Status(const std::string&, const std::string&)>
 
using StatusChangeCallback = std::function<void(const QueueStatus&)>
 

Public Member Functions

 WasmMessageQueue ()
 
 ~WasmMessageQueue ()
 
std::string Enqueue (const std::string &, const std::string &)
 
void SetOnReplayComplete (ReplayCompleteCallback)
 
void SetOnStatusChange (StatusChangeCallback)
 
void ReplayAll (MessageSender, int=3)
 
size_t PendingCount () const
 
QueueStatus GetStatus () const
 
void Clear ()
 
void ClearFailed ()
 
bool RemoveMessage (const std::string &)
 
absl::Status PersistToStorage ()
 
absl::Status LoadFromStorage ()
 
void SetAutoPersist (bool)
 
void SetMaxQueueSize (size_t)
 
void SetMessageExpiry (double)
 
std::vector< QueuedMessage > GetQueuedMessages () const
 
int PruneExpiredMessages ()
 

Detailed Description

Definition at line 226 of file wasm_message_queue.h.

Member Typedef Documentation

◆ ReplayCompleteCallback

using yaze::app::platform::WasmMessageQueue::ReplayCompleteCallback = std::function<void(int, int)>

Definition at line 244 of file wasm_message_queue.h.

◆ MessageSender

using yaze::app::platform::WasmMessageQueue::MessageSender = std::function<absl::Status(const std::string&, const std::string&)>

Definition at line 245 of file wasm_message_queue.h.

◆ StatusChangeCallback

using yaze::app::platform::WasmMessageQueue::StatusChangeCallback = std::function<void(const QueueStatus&)>

Definition at line 246 of file wasm_message_queue.h.

Constructor & Destructor Documentation

◆ WasmMessageQueue()

yaze::app::platform::WasmMessageQueue::WasmMessageQueue ( )
inline

Definition at line 248 of file wasm_message_queue.h.

◆ ~WasmMessageQueue()

yaze::app::platform::WasmMessageQueue::~WasmMessageQueue ( )
inline

Definition at line 249 of file wasm_message_queue.h.

Member Function Documentation

◆ Enqueue()

std::string yaze::app::platform::WasmMessageQueue::Enqueue ( const std::string & ,
const std::string &  )
inline

Definition at line 251 of file wasm_message_queue.h.

◆ SetOnReplayComplete()

void yaze::app::platform::WasmMessageQueue::SetOnReplayComplete ( ReplayCompleteCallback )
inline

Definition at line 252 of file wasm_message_queue.h.

◆ SetOnStatusChange()

void yaze::app::platform::WasmMessageQueue::SetOnStatusChange ( StatusChangeCallback )
inline

Definition at line 253 of file wasm_message_queue.h.

◆ ReplayAll()

void yaze::app::platform::WasmMessageQueue::ReplayAll ( MessageSender ,
int = 3 )
inline

Definition at line 254 of file wasm_message_queue.h.

◆ PendingCount()

size_t yaze::app::platform::WasmMessageQueue::PendingCount ( ) const
inline

Definition at line 255 of file wasm_message_queue.h.

◆ GetStatus()

QueueStatus yaze::app::platform::WasmMessageQueue::GetStatus ( ) const
inline

Definition at line 256 of file wasm_message_queue.h.

◆ Clear()

void yaze::app::platform::WasmMessageQueue::Clear ( )
inline

Definition at line 257 of file wasm_message_queue.h.

◆ ClearFailed()

void yaze::app::platform::WasmMessageQueue::ClearFailed ( )
inline

Definition at line 258 of file wasm_message_queue.h.

◆ RemoveMessage()

bool yaze::app::platform::WasmMessageQueue::RemoveMessage ( const std::string & )
inline

Definition at line 259 of file wasm_message_queue.h.

◆ PersistToStorage()

absl::Status yaze::app::platform::WasmMessageQueue::PersistToStorage ( )
inline

Definition at line 260 of file wasm_message_queue.h.

◆ LoadFromStorage()

absl::Status yaze::app::platform::WasmMessageQueue::LoadFromStorage ( )
inline

Definition at line 263 of file wasm_message_queue.h.

◆ SetAutoPersist()

void yaze::app::platform::WasmMessageQueue::SetAutoPersist ( bool )
inline

Definition at line 266 of file wasm_message_queue.h.

◆ SetMaxQueueSize()

void yaze::app::platform::WasmMessageQueue::SetMaxQueueSize ( size_t )
inline

Definition at line 267 of file wasm_message_queue.h.

◆ SetMessageExpiry()

void yaze::app::platform::WasmMessageQueue::SetMessageExpiry ( double )
inline

Definition at line 268 of file wasm_message_queue.h.

◆ GetQueuedMessages()

std::vector< QueuedMessage > yaze::app::platform::WasmMessageQueue::GetQueuedMessages ( ) const
inline

Definition at line 269 of file wasm_message_queue.h.

◆ PruneExpiredMessages()

int yaze::app::platform::WasmMessageQueue::PruneExpiredMessages ( )
inline

Definition at line 270 of file wasm_message_queue.h.

The documentation for this class was generated from the following file: