.map(tick -> messageService.getRecentMessages())
.subscribe(messages -> {
// the subscriber is called with List<Message> every time
// the remote service is polled
for (Message message : messages) {
log.info(message.toString())
}
})
кусок из той статьи
Обсуждают сегодня