-package de.juplo.kafka.chatroom.domain;
+package de.juplo.kafka.chat.backend.domain;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
return sink.asFlux();
}
- public Stream<Message> getMessages(long firstMessage)
+ public Stream<Message> getMessages(long first, long last)
{
return messages
.values()
.stream()
- .filter(message -> message.getSerialNumber() >= firstMessage);
+ .filter(message ->
+ {
+ long serial = message.getSerialNumber();
+ return serial >= first && serial <= last;
+ });
}