草庐IT

observation

全部标签

php - Laravel : Check with Observer if Column was Changed on Update

我正在使用Observer观察用户是否更新。每当用户更新我想检查他的email是否已更改。这样的事情可能吗?classUserObserver{/***ListentotheUsercreatedevent.**@param\App\User$user*@returnvoid*/publicfunctionupdating(User$user){//if($user->hasChangedEmailInThisUpdate())?}} 最佳答案 编辑:致谢https://stackoverflow.com/a/54307753/23

java - 如何在 RxJava 中的 Observable 中处理 map() 中的异常

我想这样做:Observable.just(bitmap).map(newFunc1(){@OverridepublicFilecall(BitmapphotoBitmap){//FilecreationthrowsIOException,//IjustwantittohittheonError()insidesubscribe()FilephotoFile=newFile(App.getAppContext().getCacheDir(),"userprofilepic_temp.jpg");if(photoFile.isFile()){//deletethefilefirstifi

android - 在 RxJava 中处理 Completable、Single、Maybe 和终止 Observable 的最佳实践

我是从Android的角度来问这个问题的,但这应该普遍适用于RxJava。作为最佳实践,我的观点是否应该始终处理短暂的Completable、Single、Maybe和终止ObservableRx类型应该在短时间内终止,但在用户关闭View时可能仍在执行?我知道当Rx链终止时,它会被释放,但这可能会在View关闭后的某个时间发生。例如,执行HTTPGET的Single。调用将完成,但可能是在View销毁之后,暂时阻止垃圾回收。如果使用CompositeDisposable来收集这样的Disposable长期存在的观点,我认为应该注意clear()或以其他方式定期删除这些Disposab

android - Android 单元测试中的模拟改造 Observable<T> 响应

我有一个API接口(interface),我正在测试一个涉及网络调用的View。@Config(emulateSdk=18)publicclassSampleViewTestextendsRobolectricTestBase{ServiceApiapiMock;@InjectSampleViewfixture;@OverridepublicvoidsetUp(){super.setUp();//injectionisperformedinsuperapiMock=mock(ServiceApi.class);fixture=newSampleView(activity);fixtur

安卓数据绑定(bind): Observable List to RecyclerView's Adapter

是他们的一种方式,通过使用新数据绑定(bind)库中的ObservableList类和MVVM模式,来避免使用"notifyItem(s)..."Adapter类的方法?如果不是,那么将ObservableList绑定(bind)到RecyclerView的最简单方法是什么?感谢您提供任何线索! 最佳答案 看看RecyclerView的适配器的以下实现:https://github.com/radzio/android-data-binding-recyclerview/blob/master/recyclerview-bindin

android - 使用 Retrofit observable 处理网络错误

在使用带有Retrofit的Observables时,您如何处理网络故障?鉴于此代码:Observableobservable=api.getApiService().getMyData();observable.doOnNext(newAction1(){@Overridepublicvoidcall(GetJobResponsegetJobResponse){//dostuffwithmydata}}).doOnError(newAction1(){@Overridepublicvoidcall(Throwablethrowable){//dostuffwitherrormessa

android - Rx Observable 定期发射值

我必须定期轮询一些RESTful端点以刷新我的android应用程序的数据。我还必须根据连接暂停和恢复它(如果手机离线,甚至不需要尝试)。我当前的解决方案正在运行,但它使用标准Java的ScheduledExecutorService执行周期性任务,但我想留在Rx范式中。这是我当前的代码,为简洁起见,省略了部分代码。userProfileObservable=Observable.create(newObservable.OnSubscribe(){@Overridepublicvoidcall(finalSubscribersubscriber){finalScheduledExec

android - RxJava : Error occurred when trying to propagate error to Observer. onError

我在Rx库中收到IllegalStateException错误,我不知道问题的根源在哪里,无论是RxJava还是我可能做错了什么。当证书固定(发生在所有服务器请求上)时发生致命崩溃,但似乎指向session超时或注销并重新登录。重现步骤(大约发生25%的时间)如下:登录、打开列表项目-一直滚动结束-注销-重新登录-打开应用程序-关闭应用程序->崩溃!有人对如何防止这种情况有任何想法吗?我在这里发现了一个类似的问题Observer.onErrorfiringoffinconsistentlyjava.lang.IllegalStateException:FatalExceptionthr

java - 替代 Java 的 Observable 类?

关闭。这个问题需要更多focused.它目前不接受答案。想要改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭6年前。Improvethisquestion我是从C#世界来到Java的,在C#世界中,观察者模式被实现为具有event关键字的一流语言结构。我看到Java从早期就有Observable类,但它显然存在实现问题并且似乎没有被广泛使用。到目前为止,我只是在我的Java代码中滚动我自己的观察者模式实现,但我总是忍不住认为必须有一个更好的替代方案来总是输出这个样板代码。Swing中有Listener类,但它们似乎不适用于非Swing代码。对于这个非常常

java - RxJava : how to compose multiple Observables with dependencies and collect all results at the end?

我正在学习RxJava,作为我的第一个实验,尝试重写thiscode中第一个run()方法中的代码(引用Netflix'sblog作为RxJava可以帮助解决的问题)使用RxJava改进其异步性,即它不会等待之前的第一个Future(f1.get())的结果继续代码的其余部分。f3依赖于f1。我知道如何处理这个问题,flatMap似乎可以解决问题:Observablef3Observable=Observable.from(executor.submit(newCallToRemoteServiceA())).flatMap(newFunc1>(){@OverridepublicObs