import java.time.LocalDateTime;
import java.util.*;
-import java.util.stream.Stream;
@RequiredArgsConstructor
return sink.asFlux();
}
- public Stream<Message> getMessages(long firstMessage)
+ public Flux<Message> getMessages(long first, long last)
{
- return messages
+ return Flux.fromStream(messages
.values()
.stream()
- .filter(message -> message.getSerialNumber() >= firstMessage);
+ .filter(message ->
+ {
+ long serial = message.getSerialNumber();
+ return serial >= first && serial <= last;
+ }));
}