diff options
| -rw-r--r-- | whisperTopic.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/whisperTopic.cpp b/whisperTopic.cpp index 0162124b..11937336 100644 --- a/whisperTopic.cpp +++ b/whisperTopic.cpp @@ -50,6 +50,7 @@ BOOST_AUTO_TEST_CASE(topic) auto w = wh->installWatch(BuildTopicMask("odd")); started = true; + set<unsigned> received; for (int iterout = 0, last = 0; iterout < 200 && last < 81; ++iterout) { @@ -57,6 +58,9 @@ BOOST_AUTO_TEST_CASE(topic) { Message msg = wh->envelope(i).open(wh->fullTopic(w)); last = RLP(msg.payload()).toInt<unsigned>(); + if (received.count(last)) + continue; + received.insert(last); cnote << "New message from:" << msg.from().abridged() << RLP(msg.payload()).toInt<unsigned>(); result += last; } |