LeviLamina
Loading...
Searching...
No Matches
Bedrock::PubSub::FIFODeferredSubscriptionHub Class Reference
+ Inheritance diagram for Bedrock::PubSub::FIFODeferredSubscriptionHub:

Public Types

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

Public Member Functions

FIFODeferredSubscriptionHuboperator= (FIFODeferredSubscriptionHub const &)
 
 FIFODeferredSubscriptionHub (FIFODeferredSubscriptionHub const &)
 
virtual void flushPendingEvents ()
 
virtual::Bedrock::PubSub::DeferredSubscriptionHub::HubType getHubType () const
 
virtual bool _runOneEvent ()
 
virtual void _enqueue (::std::function< void()>, ::Bedrock::PubSub::ConnectPosition, ::std::optional< int >)
 
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 > mUnke1f3f8
 
::ll::UntypedStorage< 8, 24 > mUnkb58fe3
 

Member Function Documentation

◆ flushPendingEvents()

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

◆ getHubType()

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

◆ _runOneEvent()

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

◆ _enqueue()

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

◆ runDeferredEvents()

virtual uint64 Bedrock::PubSub::DeferredSubscriptionHubBase::runDeferredEvents ( uint64 maxToRun)
virtualinherited

◆ runDeferredEventsForDuration()

virtual uint64 Bedrock::PubSub::DeferredSubscriptionHubBase::runDeferredEventsForDuration ( ::std::chrono::milliseconds msec)
virtualinherited

◆ clear()

virtual void Bedrock::PubSub::DeferredSubscriptionHubBase::clear ( )
virtualinherited

◆ erase()

virtual uint64 Bedrock::PubSub::DeferredSubscriptionHubBase::erase ( ::Bedrock::PubSub::RawSubscription & subscription)
virtualinherited

◆ size()

virtual uint64 Bedrock::PubSub::DeferredSubscriptionHubBase::size ( ) const
virtualinherited

◆ empty()

virtual bool Bedrock::PubSub::DeferredSubscriptionHubBase::empty ( ) const
virtualinherited

◆ _join()

virtual void Bedrock::PubSub::DeferredSubscriptionHubBase::_join ( ::Bedrock::PubSub::DeferredSubscription && subscription)
virtualinherited

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