CatapultServer
v0.5.0.1 (Elephant)
|
Go to the documentation of this file.
24 namespace cache {
class UtChangeSubscriber; }
25 namespace io {
class InputStream; }
28 namespace catapult {
namespace subscribers {
31 void ReadNextUtChange(io::InputStream& inputStream, cache::UtChangeSubscriber& subscriber);
void ReadTransactionInfos(InputStream &inputStream, model::TransactionInfosSet &transactionInfos)
Reads transaction infos from inputStream into transactionInfos.
Definition: TransactionInfoSerializer.cpp:67
Unconfirmed transactions change subscriber.
Definition: UtChangeSubscriber.h:28
virtual void notifyAdds(const TransactionInfos &transactionInfos)=0
Indicates transaction infos (transactionInfos) were added to unconfirmed transactions.
auto Read8(TIo &input)
Reads value from input.
Definition: PodIoUtils.h:90
#define CATAPULT_THROW_INVALID_ARGUMENT_1(MESSAGE, PARAM1)
Macro used to throw a catapult invalid argument with a single parameter.
Definition: exceptions.h:183
std::unordered_set< TransactionInfo, EntityInfoHasher< const Transaction >, EntityInfoComparer< const Transaction > > TransactionInfosSet
Unordered set of transaction infos.
Definition: ContainerTypes.h:50
virtual void notifyRemoves(const TransactionInfos &transactionInfos)=0
Indicates transaction infos (transactionInfos) were removed from unconfirmed transactions.
Definition: AddressExtractionExtension.cpp:28
Remove transaction infos.
void ReadNextUtChange(io::InputStream &inputStream, cache::UtChangeSubscriber &subscriber)
Reads next unconfirmed transactions change from inputStream and forwards it to subscriber.
Definition: UtChangeReader.cpp:30