From a4ff53302f3ec3f6d8bc52afa6a594acfeeb045f Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Mon, 18 Nov 2024 11:02:51 -0500
Subject: rmulticast.Message: add isSentBy() method

---
 src/main/java/derms/net/rmulticast/ReceivedSet.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'src/main/java/derms/net/rmulticast/ReceivedSet.java')

diff --git a/src/main/java/derms/net/rmulticast/ReceivedSet.java b/src/main/java/derms/net/rmulticast/ReceivedSet.java
index 91ef95d..16b586b 100644
--- a/src/main/java/derms/net/rmulticast/ReceivedSet.java
+++ b/src/main/java/derms/net/rmulticast/ReceivedSet.java
@@ -57,7 +57,7 @@ class ReceivedSet<T extends MessagePayload> {
     Message<T> mostRecentSentBy(InetAddress member) throws NoSuchElementException {
         Entry<T> recent = null;
         for (Entry<T> e : received.values())
-            if (e.msg.sender.equals(member) && (recent == null || e.timestamp.isAfter(recent.timestamp)))
+            if (e.msg.isSentBy(member) && (recent == null || e.timestamp.isAfter(recent.timestamp)))
                 recent = e;
         if (recent == null)
             throw new NoSuchElementException("no message from " + member + " in received list.");
@@ -67,7 +67,7 @@ class ReceivedSet<T extends MessagePayload> {
     List<Message<T>> allSentBy(InetAddress sender) {
         List<Message<T>> sent = new ArrayList<Message<T>>();
        for (Entry<T> e : received.values()) {
-           if (e.msg.sender.equals(sender))
+           if (e.msg.isSentBy(sender))
                sent.add(e.msg);
        }
        return sent;
-- 
cgit v1.2.3