如何转换单声道流到通量或减少单声道流到单声道使用和操作
我的代码如下。我需要从mongo db获得每次旅行的车费，然后将每次旅行的所有车费相加，得到总车费。我被一种我不知道如何阅读的单声道音乐所困扰。我试着把它转换成通量，但我得到了通量
private int calculateDailyRate(final Entry<LocalDate, List<Trip>> entry) {
int dailyFare = 0;
List<Trip> trips = entry.getValue();
// Get the fare for each trip, and then sum up the list of fares to get the daily total fare
trips.stream().map(trip->fareLookupRepo.getFareRules(trip.getSecondOfDay(), trip.getTripDate().getDayOfWeek().getValue(),
trip.getFromZone(), trip.getToZone()).sort(Comparator.comparing(FareRule::getRate)).next().map(FareRule::getRate));
return dailyFare;
}
"'
共有1个答案
我不确定你的逻辑是否正确，因为你可以是完整的日期。
但这里有一个提示，告诉你如何去做你想做的事情。
return Flux.fromIterable(trips)
.flatMap(trip-> fareLookupRepo.getFareRules(trip.getSecondOfDay(), trip.getTripDate().getDayOfWeek().getValue(),
trip.getFromZone(), trip.getToZone())
.flatMap(trip-> Mono.just(trip.getRate())))
.reduce(0, (x1, x2)-> x1 + x2)
注意：fareLookupRepo.getFareLaw它应该返回mono
-
我有一个方法，可以尝试使用WebClient返回Mono 它可以返回我期望的结果。然后我尝试创建另一个方法来支持列表作为参数 但这一次返回一个奇怪的结果。 我是反应式编程新手，将流和单声道结合起来，然后转换为流量的正确方法是什么？
-
问题内容： 我在这里遇到以下问题：我得到了一个代表音频数据的字节块（uint16_t *），并且生成它们的设备正在捕获单声道声音，因此很明显，我在1通道上具有单声道音频数据。我需要将此数据传递到另一台设备，该设备需要交错的立体声数据（因此为2个通道）。我要做的基本上是复制数据中的1通道，以便立体声数据的两个通道都包含相同的字节。您能指出一个有效的算法吗？ 谢谢，f。 问题答案： 如果只需要交错的立
-
使用spring 5，对于reactor，我们有以下需求。 什么方法可以转换单声道
-
我的REST控制器方法应该返回Mono，它必须由两个并行请求构建到另一个web服务，并处理它们的响应，其中一个请求返回Mono，另一个请求返回Flux 如何将单声道的响应与熔剂的响应结合起来进行处理？ 显然，控制器是错误的，因为: 1)接受2个或更多的Mono，其中我有Mono和Flux-如何将它们组合起来？ 2)也不确定: 是否正确？ 有什么建议吗？
-
给定以下monos: 双： 和： 具有相同的输出： 和之间有什么区别，在这种情况下？ 从https://projectreactor.io/docs/core/release/reference/index.html#which-operator： [如果你]有一个序列，但[你]对值不感兴趣，并且[你]想在最后切换到另一个单声道，[使用]。 [如果您]希望通过将发布者从1个Mono和任何源端协调到
-
我有两项要求： 有了这些，我想做以下工作： 当我调用它时，我得到以下输出： 当然，由于异步单声道映射，流在结果实际出现之前就关闭了。我怎样才能保持这个非阻塞，但也确保结果在调用上完成之前到达？