.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())
                  
                  
                              }
                  
                  
                            })
                  
                  
                
кусок из той статьи
Обсуждают сегодня