回答情况：
提问时间：
问题标签：
Publisher<Object> publisher = new MyAwesomelyReactivePublisher<>();Flowable.unsafeCreate(publisher);Flowable.fromPublisher(publisher);
两者的用例是什么？
浏览 1提问于2018-02-28得票数 0
回答已采纳
RxJava 2.0.5引入了ParallelFlowable类型，对应于Flowable.parallel()操作符。我发现实现并行性的一般建议是使用flatMap，如下所示： .flatMap(x -> Flowable.just(x)
.observeOn
浏览 1提问于2017-05-31得票数 8
回答已采纳
public Flowable<Integer> simple(int number) { } }, BackpressureStrategy.BUFFER);
flowable= flowable.subscribeOn(S
浏览 0提问于2017-02-04得票数 0
回答已采纳
你好，我是RxJava的新手，我有一个接收Flowable<Item> f2的类，我需要从它获取值，而不需要更改任何数据(将值保存到本地缓存)。然后将其与其他Flowable f1连接，并将其发送到更高级别的类。是否可以从f2中只发出一次值 另外，我如何对来自Flowable f1的所有项目执行操作，但在n个项目之后从f1创建新的Flowable f2。
浏览 21提问于2019-05-28得票数 0
回答已采纳
在我的应用程序中，我收到了一个Flowable<ListenableFuture<List<Integer>>。(ListenableFuture来自番石榴。)我怎样才能把这个可流动的流压成一个Flowable<Integer>Flowable<ListenableFuture<List<Integer>>> futures = ...Flowable<Integer> ints = futures.flatMap(f
浏览 4修改于2016-10-25得票数 1
回答已采纳
我有一台Flowable和一台Observable。但是，只有当Observable的值出现时，Flowable才应该为request。
浏览 0提问于2018-08-10得票数 0
我正在尝试从一个Spring RestController向一个使用Retrofit和Rxjava的安卓应用程序发送一个io.reactivex.Flowable。弹簧控制器： @GetMapping("/api/reactive") return Flowable.interval(1, TimeUnit.SECONDS).map(sequence -> "\"<e
浏览 73修改于2020-04-10得票数 0
database.leadsDao().getLeads(leadState.name) val len = it.size.toLong() .flatMap { database.orderDao()流一直在等待更多的项，这是不应该发生的，因为Flowable.fromIterable给出了有限
浏览 2提问于2017-08-27得票数 3
回答已采纳
我有以下rxJava链： varcombinedFlowable = Flowable req,} .addTo(disposables)
但是，当没有位置
浏览 1提问于2018-07-19得票数 11
这是我的刀： @Query("SELECT * FROM favorites ORDER BY lastConsultation DESC") .flatMap { Flowable.just(it)
浏览 23修改于2019-09-18得票数 0
回答已采纳
我正在使用Flowable.generate构建一个Kafka consumer Flowable，下面是我的实现import io.reactivex.rxjava3.core.Flowable; */
public static @NonNull F
浏览 12提问于2021-06-06得票数 0
我很难理解Flowable在房间中是如何工作的。OnConflictStrategy.REPLACE)Flowable<List<Site>> getSites();priv
浏览 0修改于2017-12-26得票数 2
getBarId();} String id();} sendMessage(f.getMessage(), bar.getDescription());所以我有返回Flowable
浏览 4修改于2018-04-02得票数 1
RxJava2中是否有任何运算符可以应用从Flowable到Single或Maybe的转换？我的意思是Flowable.compose()操作符将Transformer应用于Flowable并返回另一个Flowable。但是，我需要应用一个转换器，它可以将Flowable转换为Single或Mabye，并且可以在应用程序中多次重用，而不需要"“。示例(以Kotlin表示)：
fun processFirstEven(f: Flowable<Int>): Maybe&
浏览 0修改于2019-02-03得票数 1
我正在尝试集成Spring Boot 2.0.2和Flowable 6.3.1。未拾取XML文件，错误为： at org.flowable.engine.impl.repository.DeploymentBuilderImpl.addClasspathResourc
浏览 51提问于2018-08-10得票数 0
private val flowableList: Flowable<List<T>>
private val list = listOf<T>(flowableList)
浏览 16修改于2019-08-11得票数 0
final List<Integer> data = List.of(1, 2, 3); .take(data.size
浏览 43提问于2020-07-25得票数 0
回答已采纳
flowable:type="mail" > <flowable:field name="to"> </flowable:field>
<flowable<
浏览 13提问于2019-04-01得票数 0
我正在将应用程序bpmn引擎从Activiti5迁移到Flowable6。目前我有一个问题，因为我在Activi5中使用的当前流程定义是.bpmn文件，所以如果我想在Flowable6中使用它们，我需要做任何修改吗？P/s:我在https://flowable.com/open-source/docs/migration/阅读了可流动迁移指南，但没有找到任何关于这方面的信息。
浏览 90提问于2021-06-28得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号