| 159 | } |
| 160 | |
| 161 | void CZMQNotificationInterface::BlockConnected(const std::shared_ptr<const CBlock>& pblock, const CBlockIndex* pindexConnected) |
| 162 | { |
| 163 | for (const CTransactionRef& ptx : pblock->vtx) { |
| 164 | const CTransaction& tx = *ptx; |
| 165 | TryForEachAndRemoveFailed(notifiers, [&tx](CZMQAbstractNotifier* notifier) { |
| 166 | return notifier->NotifyTransaction(tx); |
| 167 | }); |
| 168 | } |
| 169 | |
| 170 | // Next we notify BlockConnect listeners for *all* blocks |
| 171 | TryForEachAndRemoveFailed(notifiers, [pindexConnected](CZMQAbstractNotifier* notifier) { |
| 172 | return notifier->NotifyBlockConnect(pindexConnected); |
| 173 | }); |
| 174 | } |
| 175 | |
| 176 | void CZMQNotificationInterface::BlockDisconnected(const std::shared_ptr<const CBlock>& pblock, const CBlockIndex* pindexDisconnected) |
| 177 | { |
nothing calls this directly
no test coverage detected