Inheritance diagram for Bedrock::PubSub::PriorityDeferredSubscriptionHub:

Classes
struct	DequeuedEntry
struct	QueueEntry

Public Types
using	DequeuedItemsType = ::std::deque<::Bedrock::PubSub::PriorityDeferredSubscriptionHub::DequeuedEntry>
using	QueueType
enum class	HubType : int { Priority = 0 , Fifo = 1 , RecursiveFIFO = 2 }
using	FunctionType = ::brstd::move_only_function<void()>

Public Member Functions
virtual void	flushPendingEvents ()
virtual::Bedrock::PubSub::DeferredSubscriptionHub::HubType	getHubType () const
virtual bool	_runOneEvent ()
virtual void	_enqueue (::brstd::move_only_function< void()> fn, ::Bedrock::PubSub::ConnectPosition at, ::std::optional< int > group)
virtual void	_runDequeuedEntry (::Bedrock::PubSub::PriorityDeferredSubscriptionHub::DequeuedEntry &&entry)
MCAPI void	$flushPendingEvents ()
MCFOLD::Bedrock::PubSub::DeferredSubscriptionHub::HubType	$getHubType () const
MCAPI bool	$_runOneEvent ()
MCAPI void	$_enqueue (::brstd::move_only_function< void()> fn, ::Bedrock::PubSub::ConnectPosition at, ::std::optional< int > group)
MCFOLD void	$_runDequeuedEntry (::Bedrock::PubSub::PriorityDeferredSubscriptionHub::DequeuedEntry &&entry)
virtual uint64	runDeferredEvents (uint64 maxToRun)
virtual uint64	runDeferredEventsForDuration (::std::chrono::milliseconds msec)
virtual void	clear ()
virtual uint64	erase (::Bedrock::PubSub::RawSubscription &subscription)
virtual uint64	size () const
virtual bool	empty () const
virtual void	_join (::Bedrock::PubSub::DeferredSubscription &&subscription)
MCAPI void	$dtor ()
MCAPI uint64	$runDeferredEvents (uint64 maxToRun)
MCAPI uint64	$runDeferredEventsForDuration (::std::chrono::milliseconds msec)
MCAPI void	$clear ()
MCAPI uint64	$erase (::Bedrock::PubSub::RawSubscription &subscription)
MCAPI uint64	$size () const
MCFOLD bool	$empty () const
MCAPI void	$_join (::Bedrock::PubSub::DeferredSubscription &&subscription)

Static Public Member Functions
static MCAPI void **	$vftable ()
static MCAPI ::std::unique_ptr<::Bedrock::PubSub::DeferredSubscriptionHub >	makePriorityHub ()

Public Attributes
::ll::TypedStorage< 8, 560, ::Bedrock::MPSCQueue< ::Bedrock::PubSub::PriorityDeferredSubscriptionHub::QueueEntry, 64, ::std::allocator<::Bedrock::PubSub::PriorityDeferredSubscriptionHub::QueueEntry >, 0 > >	mQueue
::ll::TypedStorage< 8, 40, ::std::deque<::Bedrock::PubSub::PriorityDeferredSubscriptionHub::DequeuedEntry > >	mDequeuedItems
::ll::TypedStorage< 8, 24, ::std::vector<::Bedrock::PubSub::DeferredSubscription > >	mSubscriptions

Member Typedef Documentation

◆ QueueType

using Bedrock::PubSub::PriorityDeferredSubscriptionHub::QueueType

Initial value:

::Bedrock::MPSCQueue<
       ::Bedrock::PubSub::PriorityDeferredSubscriptionHub::QueueEntry,
       64,
       ::std::allocator<::Bedrock::PubSub::PriorityDeferredSubscriptionHub::QueueEntry>,
       0>

Member Function Documentation

◆ flushPendingEvents()

virtual void Bedrock::PubSub::PriorityDeferredSubscriptionHub::flushPendingEvents ( )

virtual

Implements Bedrock::PubSub::DeferredSubscriptionHub.

◆ getHubType()

virtual::Bedrock::PubSub::DeferredSubscriptionHub::HubType Bedrock::PubSub::PriorityDeferredSubscriptionHub::getHubType ( ) const

virtual

Implements Bedrock::PubSub::DeferredSubscriptionHub.

◆ _runOneEvent()

virtual bool Bedrock::PubSub::PriorityDeferredSubscriptionHub::_runOneEvent ( )

virtual

Implements Bedrock::PubSub::DeferredSubscriptionHubBase.

◆ _enqueue()

virtual void Bedrock::PubSub::PriorityDeferredSubscriptionHub::_enqueue	(	::brstd::move_only_function< void()>	fn,
		::Bedrock::PubSub::ConnectPosition	at,
		::std::optional< int >	group )

virtual

Implements Bedrock::PubSub::DeferredSubscriptionHub.

◆ $vftable()

MCAPI void ** Bedrock::PubSub::PriorityDeferredSubscriptionHub::$vftable ( )

static

Attention: This function is not yet publicly available. To request access: reference this function in your code and attempt to link. The linker will report the exact symbol name. Submit a access request at https://github.com/LiteLDev/mcapi-requests/issues/new including the full symbol name.