Observer::detail::RecordList Struct Reference

#include <Observer.h>

Inheritance diagram for Observer::detail::RecordList:

Collaboration diagram for Observer::detail::RecordList:

Public Types
using	Visitor = bool(*)(const RecordBase &record, const void *arg)
	Type of function visiting the list; stop visit on true return. More...

Public Member Functions
	RecordList (ExceptionPolicy *pPolicy, Visitor visitor)
	~RecordList () noexcept
Subscription	Subscribe (std::shared_ptr< RecordBase > pRecord)
bool	Visit (const void *arg)

Private Attributes
ExceptionPolicy *const	m_pPolicy
const Visitor	m_visitor

Additional Inherited Members
Public Attributes inherited from Observer::detail::RecordLink
std::shared_ptr< RecordBase >	next

Detailed Description

Definition at line 53 of file Observer.h.

Member Typedef Documentation

Visitor

using Observer::detail::RecordList::Visitor = bool(*)(const RecordBase &record, const void *arg)

Type of function visiting the list; stop visit on true return.

Definition at line 56 of file Observer.h.

Constructor & Destructor Documentation

RecordList()

Observer::detail::RecordList::RecordList ( ExceptionPolicy *  pPolicy, Visitor  visitor  )

explicit

Precondition

visitor != nullptr

Definition at line 26 of file Observer.cpp.

   : m_pPolicy{ pPolicy }
   , m_visitor{ visitor }
{
   assert(m_visitor); // precondition
}

References m_visitor.

~RecordList()

Observer::detail::RecordList::~RecordList ( )

noexcept

Non-defaulted destructor. Beware stack growth

Definition at line 33 of file Observer.cpp.

{
   auto pRecord = move(next);
   while (pRecord)
      pRecord = move(pRecord->next);
}

References Observer::detail::RecordLink::next.

Member Function Documentation

Subscribe()

Subscription Observer::detail::RecordList::Subscribe

(

std::shared_ptr< RecordBase >

pRecord

)

Precondition

pRecord != nullptr

Definition at line 41 of file Observer.cpp.

{
   assert(pRecord); // precondition
   auto result = Subscription{ pRecord };
   if (auto &pNext = (pRecord->next = move(next)))
      pNext->prev = pRecord;
   pRecord->prev = weak_from_this();
   next = move(pRecord);
   return result;
}

References Observer::detail::RecordLink::next.

Visit()

bool Observer::detail::RecordList::Visit

(

const void *

arg

)

Definition at line 52 of file Observer.cpp.

{
   assert(m_visitor); // See constructor
   if (m_pPolicy)
      m_pPolicy->OnBeginPublish();
   bool result = false;
   for (auto pRecord = next; pRecord; pRecord = pRecord->next) {
      try {
         if (m_visitor(*pRecord, arg)) {
            result = true;
            break;
         }
         // pRecord might have been removed from the list by the callback,
         // but pRecord->next is unchanged.  We won't see callbacks added by
         // the callback, because they are earlier in the list.
      }
      catch (...) {
         if (m_pPolicy && m_pPolicy->OnEachFailedCallback()) {
            result = true;
            break;
         }
      }
   }
   // Intentionally not in a finally():
   if (m_pPolicy)
      m_pPolicy->OnEndPublish();
   return result;
}

References m_pPolicy, m_visitor, Observer::detail::RecordLink::next, Observer::ExceptionPolicy::OnBeginPublish(), Observer::ExceptionPolicy::OnEachFailedCallback(), and Observer::ExceptionPolicy::OnEndPublish().

Here is the call graph for this function:

Member Data Documentation

m_pPolicy

ExceptionPolicy* const Observer::detail::RecordList::m_pPolicy

private

Definition at line 64 of file Observer.h.

Referenced by Visit().

m_visitor

const Visitor Observer::detail::RecordList::m_visitor

private

Definition at line 65 of file Observer.h.

Referenced by RecordList(), and Visit().

---

The documentation for this struct was generated from the following files:

• Observer.h
• Observer.cpp