FlowableEmitter无法发出项目

文章/答案/技术大牛

发布

1回答

rx-java2

但是，当文件同时到达这两个目录时，其中任何一个目录中的某些文件都无法发出。代码如下： Flowable.create((FlowableEmitter<Path> em) -> pollDirectory(Arrays.asList(dir1,dir2), em),; handleException(e);} FileAlterationListenerImpl类在创建文件时发出路径，代码如下： public clas

浏览 36提问于2021-07-27得票数 0

1回答

多个可流动的observedOn单调度程序，事件不按发出的顺序使用

java、rx-java2、scheduler、backpressure

我有： final Scheduler scheduler = Schedulers.from(executor);

浏览 0提问于2019-03-04得票数 0

1回答

具有自定义计数标准的RxJava缓冲区/窗口

kotlin、rx-java、rx-java2

我有一个Observable，它发出许多对象，我希望使用window或buffer操作对这些对象进行分组。但是，我希望能够使用自定义条件，而不是指定count参数来确定窗口中应该有多少个对象。例如，假设observable正在发出如下所示的Message类的实例。

浏览 34提问于2018-10-13得票数 2

回答已采纳

1回答

当FlowableEmitter获得null时，onNext不会发出错误信号

rx-java

我预计当我将null设置为onNext的参数时，FlowableEmitter会发出错误信号，因为2.0中的不同之处是以下内容将立即产生NullPointerException或作为向下游发出的信号：然而，它似乎称之为onComplete。

浏览 6提问于2016-09-21得票数 1

回答已采纳

1回答

rxjava2 -如何阻止，直到回叫完成，然后进行改造调用？

rx-java、rx-java2

我很难使用BlockingObservable。我有一种情况，我需要回叫已完成，然后在它完成之后，我可以做一个修改API调用来获取数据。具体来说，我需要先初始化一个支付网关sdk，然后在它成功初始化之后，我将进行一个更新调用。以下是我到目前为止所拥有的： public PaymentStrategy call() throws Exception {

浏览 9提问于2017-07-29得票数 0

2回答

RxJava2 -在平行线上发射onError将得到UndeliverableException

java、rx-java、rx-java2

虽然其中一个轨道发出了onError()，但另一个rails中的isCancelled()仍然返回false，这将导致UndeliverableException。如何检查下游是否取消了平行轨道？disposable = Flowable.create(new FlowableOnSubscribe<Integer>() { public void subscribe(FlowableEmitterFlowableOnSubscribe<String>() {

浏览 1提问于2018-04-24得票数 1

回答已采纳

1回答

为Rx v2 Flowable编写同步单元测试

java、android、rx-java、reactive-programming、rx-android

我正在将我的项目从Rx v1转换为Rx v2，目前我正在将一些v1 Observable转换为v2 Flowable。(它在Android项目中，使用Spock在Groovy中编写单元测试) @Override void subscribe(FlowableEmitter</em

浏览 18提问于2016-09-22得票数 3

回答已采纳

1回答

RxJava 2，释放DisposableSubscriber时未调用Flowable.doOnCancel

java、rx-java、rx-java2

现在，我在DisposableSubscriber上调用了.dispose()，但是Flowable继续发出事件。最终，可流动的超时和.doOnCancel()被调用。getFlowable() { public void subscribe(FlowableEmitterstopSomeAsyncProcess(); });调用stop()在可流动超时之前处理DisposableS

浏览 2提问于2017-11-15得票数 0

1回答

布尔扫描没有发现设备。

android、bluetooth-lowenergy

org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"repositories {} Build.gradle(项目

浏览 1提问于2018-06-27得票数 0

1回答

可观测支座无功拉力

rx-java、reactive-programming、rx-java2、backpressure

我有一个Flowable，它从网络中检索一捆项目并发出它们。Flowable @Override public void subscribe(FlowableEmitter

浏览 2提问于2017-02-28得票数 0

回答已采纳

1回答

使用RxJava2创建一个具有生成函数的可流动的

java、kotlin、observable、rx-java2、backpressure

这意味着当下游请求5项时，我将“询问数据源”项0- 5，然后当下游需要另一项时，我将得到项目5- 10并发出返回。另一方面，当您使用Flowable.create时，您将得到具有long requested()方法的FlowableEmitter。

浏览 2提问于2017-11-09得票数 0

回答已采纳

1回答

RxJava与用户创建的可流合并仅发出最后一个可流动的

java、rx-java、rx-java2

当我在由Flowable.merge()创建的两个可流(a1，a2)上使用Flowable.create()时，它只会发出a2。但是，当我在由b1 ()创建的两个可流动( b2，Flowable.interval)上合并时，它将像我所期望的那样发出b1和b2。以下是我的问题的简单演示： private static FlowableEmitter<Integer> emitter;

浏览 2提问于2018-01-08得票数 1

回答已采纳

1回答

找不到封装方法的空lambda$getTestFlowable$0(io.reactivex.FlowableEmitter)‘

java、android、proguard、rx-java2、retrolambda

我在我的项目中使用了RxJava2和Retrolambda，一段时间以来，我感觉非常好，将回调包装为可流动的，但是有一天我遇到了这个错误，如果我试图在这个非常简单的代码片段上运行proguard：} 然后，我将得到这个警告，这将使我的构建失败: com.yandex.testfield.MainActivity$1: com.yandex.testfield.MainActivity$1:无法找到程序类私有可流动的getTestFlowable() {返回Flowable.create(新的FlowableOnSubscribe() {@覆盖公共空订阅(<e

浏览 5提问于2017-05-12得票数 1

1回答

我怎么安装sebek？

kernel

首先，我无法得到一个sebek客户端，它的版本喜欢3.2.0b。当我得到一个soruce代码时，它仍然失败了，因为Ubuntu的内核版本不是2.6。有人有好主意吗？

浏览 0提问于2015-08-10得票数 0

1回答

HTTP头替代

http、amazon-cloudfront、cdn

它为新项目返回错误403。在向新项目发出HEAD请求之前，我必须发出GET请求，否则我的HEAD请求始终返回403。我无法更改有关我的服务器的任何内容。我还有其他选择吗？我真的不想下载这些项目来做存在检查(这些项目是图片)。

浏览 0提问于2018-06-27得票数 0

1回答

Subclipse无法重命名文件(OS X)

java、eclipse、svn、subclipse

我不能在我的Eclipse项目上执行任何Subversion操作，因为Subclipse不能重命名文件。

浏览 0提问于2009-11-20得票数 13

回答已采纳

1回答

ListView项目列表为空，但SelectedItems中仍有元素(c#/wpf)

c#、wpf

我使用该项目的IsSelected属性取消选择该项目，但这不起作用。即使在我做了itemsList.SelectedItems.Clear()/RemoveAt(0)/UnselectAll()之后，它仍然有一个选中的项目。任何帮助都是非常感谢的。谢谢

浏览 1提问于2018-03-23得票数 1

1回答

识别WEBDav结果中的附件

php、exchange-server、webdav

tl;dr -无法通过webdav服务检索电子邮件的附件列表。

浏览 0提问于2011-11-04得票数 0

回答已采纳

2回答

Adobe Captivate 3键入声音查看录音

adobe、adobe-captivate

有时，当我禁用此“功能”并录制时，它不会发出打字声音，但当我发布项目时，打字声音会返回。此外，我还有其他正在做的项目，在录音过程中，打字声音最初并没有被禁用，我无法让它停止发出打字噪音。关于如何在新的或现有的Captivate项目中永久禁用打字声音，有什么建议吗？

浏览 2提问于2008-09-20得票数 0

回答已采纳

1回答

在android中，新的请求比通过listview传递参数更好吗？

android、json、listview、httprequest

我在Android中做了一个列表视图，它从一个带有一些信息的json中获取数据，我想知道用一个项目的所有数据创建一个新活动的最快方法。在意图中传递项目的id和在新活动中发出新请求，还是在意图中传递新活动的所有数据，哪个更有效？我猜发出两个请求比发出一个请求并在intent中传递数据更糟糕，但可能这个信息太大而无法在intent.putextra()中传递；谢谢!

浏览 1提问于2013-04-17得票数 0

点击加载更多