小编Adh*_*ita的帖子

执行时间响应式编程

这是getFavouriteDetails()在反应式编程中找到方法 ( )执行时间的理想方法吗?

public List<Favourites> getFavouriteDetails(String userId){
    userService.getFavorites(userId) 
               .flatMap(favoriteService::getDetails) 
               .switchIfEmpty(suggestionService.getSuggestions()) 
               .take(5) 
               .publishOn(UiUtils.uiThreadScheduler()) 
               .subscribe(uiList::show, UiUtils::errorPopup)
               .flatMap(a -> Mono.subscriberContext().map(ctx -> {
                         log.info("Time taken : " + Duration.between(ctx.get(key), Instant.now()).toMillis() + " milliseconds.");
                         return a;
                     }))
               .subscriberContext(ctx -> ctx.put(key, Instant.now()))
}
Run Code Online (Sandbox Code Playgroud)

spring reactive-programming project-reactor

6
推荐指数
2
解决办法
3386
查看次数