Inheritance diagram for Bedrock::PubSub::PriorityDeferredSubscriptionHub:

Classes
struct	DequeuedEntry

struct	QueueEntry

Public Types
enum class	HubType : int { Priority = 0 , Fifo = 1 , RecursiveFIFO = 2 }

Public Member Functions
PriorityDeferredSubscriptionHub &	operator= (PriorityDeferredSubscriptionHub const &)

	PriorityDeferredSubscriptionHub (PriorityDeferredSubscriptionHub const &)

virtual void	flushPendingEvents ()

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

virtual bool	_runOneEvent ()

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

virtual void	_runDequeuedEntry (::Bedrock::PubSub::PriorityDeferredSubscriptionHub::DequeuedEntry const &entry)

MCAPI void *	$ctor ()

MCAPI void	$flushPendingEvents ()

MCFOLD::Bedrock::PubSub::DeferredSubscriptionHub::HubType	$getHubType () const

MCAPI bool	$_runOneEvent ()

MCAPI void	$_enqueue (::std::function< void()> fn, ::Bedrock::PubSub::ConnectPosition at, ::std::optional< int > group)

MCAPI void	$_runDequeuedEntry (::Bedrock::PubSub::PriorityDeferredSubscriptionHub::DequeuedEntry const &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

MCAPI bool	$empty () const

MCAPI void	$_join (::Bedrock::PubSub::DeferredSubscription &&subscription)

Static Public Member Functions
static MCAPI void **	$vftable ()

Public Attributes
::ll::UntypedStorage< 8, 560 >	mUnk31088e

::ll::UntypedStorage< 8, 40 >	mUnkbc9ae5

::ll::UntypedStorage< 8, 24 >	mUnkb58fe3

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	(	::std::function< void()>	fn,
		::Bedrock::PubSub::ConnectPosition	at,
		::std::optional< int >	group )