CatapultServer  v0.5.0.1 (Elephant)
ReverseNotificationObserverAdapter.h
Go to the documentation of this file.
1 
21 #pragma once
22 #include "ObserverTypes.h"
24 
25 namespace catapult { namespace model { class TransactionRegistry; } }
26 
27 namespace catapult { namespace observers {
28 
31  private:
33  using NotificationPublisherPointer = std::unique_ptr<const model::NotificationPublisher>;
34 
35  public:
38 
39  public:
40  const std::string& name() const override;
41 
42  void notify(const model::WeakEntityInfo& entityInfo, ObserverContext& context) const override;
43 
44  private:
47  };
48 }}
NotificationPublisher.h
catapult::observers::ReverseNotificationObserverAdapter::ReverseNotificationObserverAdapter
ReverseNotificationObserverAdapter(NotificationObserverPointer &&pObserver, NotificationPublisherPointer &&pPublisher)
Creates a new adapter around pObserver and pPublisher.
Definition: ReverseNotificationObserverAdapter.cpp:52
catapult::observers::ReverseNotificationObserverAdapter::NotificationObserverPointer
NotificationObserverPointerT< model::Notification > NotificationObserverPointer
Definition: ReverseNotificationObserverAdapter.h:32
catapult::observers::ReverseNotificationObserverAdapter
A notification observer to entity observer adapter that reverses the order of raised notifications.
Definition: ReverseNotificationObserverAdapter.h:30
m_notificationBuffers
std::vector< std::vector< uint8_t > > m_notificationBuffers
Definition: ReverseNotificationObserverAdapter.cpp:48
catapult::observers::ObserverContext
Context passed to all the observers.
Definition: ObserverContext.h:78
catapult::observers::ReverseNotificationObserverAdapter::notify
void notify(const model::WeakEntityInfo &entityInfo, ObserverContext &context) const override
Notifies the observer with an entityInfo to process and an observer context.
Definition: ReverseNotificationObserverAdapter.cpp:63
catapult::model::NotificationChannel::Observer
Publish notification on observer channel.
catapult::model::IsSet
constexpr bool IsSet(NotificationType type, NotificationChannel channel)
Checks if type has channel set.
Definition: NotificationType.h:61
catapult::validators::Notification
model::AccountAddressNotification Notification
Definition: AddressValidator.cpp:27
catapult::observers::EntityObserver
Definition: EntityObserver.h:30
NotificationSubscriber.h
ObserverTypes.h
catapult::observers::ReverseNotificationObserverAdapter::m_pPublisher
NotificationPublisherPointer m_pPublisher
Definition: ReverseNotificationObserverAdapter.h:46
catapult::observers::ReverseNotificationObserverAdapter::NotificationPublisherPointer
std::unique_ptr< const model::NotificationPublisher > NotificationPublisherPointer
Definition: ReverseNotificationObserverAdapter.h:33
catapult::model::WeakEntityInfoT
Wrapper around a strongly typed entity and its associated metadata.
Definition: WeakEntityInfo.h:33
TransactionPlugin.h
catapult::observers::ReverseNotificationObserverAdapter::name
const std::string & name() const override
Gets the observer name.
Definition: ReverseNotificationObserverAdapter.cpp:59
catapult::timesync::filters::CreateReversedTimestampsFilter
SynchronizationFilter CreateReversedTimestampsFilter()
Creates a filter that filters out samples where send and receive timestamps don't have proper order.
Definition: ReversedTimestampsFilter.cpp:26
catapult::observers::NotificationObserver
NotificationObserverT< model::Notification > NotificationObserver
A notification observer for processing a generic Notification.
Definition: ObserverTypes.h:30
catapult::observers::NotificationObserverPointerT
std::unique_ptr< const NotificationObserverT< TNotification > > NotificationObserverPointerT
A notification observer (unique) pointer.
Definition: ObserverTypes.h:34
catapult::timesync::filters::SynchronizationFilter
predicate< const TimeSynchronizationSample &, NodeAge > SynchronizationFilter
Signature of a synchronization filter.
Definition: SynchronizationFilters.h:29
ReverseNotificationObserverAdapter.h
catapult::observers::ReverseNotificationObserverAdapter::m_pObserver
NotificationObserverPointer m_pObserver
Definition: ReverseNotificationObserverAdapter.h:45
catapult
Definition: AddressExtractionExtension.cpp:28
SynchronizationFilters.h
ContainerHelpers.h