mirror of
https://github.com/bisq-network/bisq.git
synced 2024-11-19 09:52:23 +01:00
Refactor: Rename
This commit is contained in:
parent
4c7b56072f
commit
504fb2e6a1
@ -79,7 +79,7 @@ public class CleanupMailboxMessages {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void cleanupMailboxMessages(List<Trade> trades) {
|
private void cleanupMailboxMessages(List<Trade> trades) {
|
||||||
mailboxMessageService.getMailBoxMessages()
|
mailboxMessageService.getMyMailBoxMessages()
|
||||||
.forEach(message -> handleDecryptedMessageWithPubKey(message, trades));
|
.forEach(message -> handleDecryptedMessageWithPubKey(message, trades));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -88,7 +88,7 @@ public abstract class TradeProtocol implements DecryptedDirectMessageListener, D
|
|||||||
// change and leave that for a later PR
|
// change and leave that for a later PR
|
||||||
UserThread.runAfter(() -> {
|
UserThread.runAfter(() -> {
|
||||||
mailboxMessageService.addDecryptedMailboxListener(this);
|
mailboxMessageService.addDecryptedMailboxListener(this);
|
||||||
mailboxMessageService.getMailBoxMessages()
|
mailboxMessageService.getMyMailBoxMessages()
|
||||||
.forEach(this::handleDecryptedMessageWithPubKey);
|
.forEach(this::handleDecryptedMessageWithPubKey);
|
||||||
}, 100, TimeUnit.MILLISECONDS);
|
}, 100, TimeUnit.MILLISECONDS);
|
||||||
}
|
}
|
||||||
|
@ -245,7 +245,7 @@ public class MailboxMessageService implements SetupListener, RequestDataManager.
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public Set<DecryptedMessageWithPubKey> getMailBoxMessages() {
|
public Set<DecryptedMessageWithPubKey> getMyMailBoxMessages() {
|
||||||
return mailboxItemsByUid.values().stream()
|
return mailboxItemsByUid.values().stream()
|
||||||
.filter(list -> !list.isEmpty())
|
.filter(list -> !list.isEmpty())
|
||||||
.map(list -> list.get(0))
|
.map(list -> list.get(0))
|
||||||
|
Loading…
Reference in New Issue
Block a user